本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
第 3 步:创建客户端计算机
在步骤中,您将执行下面两个任务。第一项任务是创建一个 Amazon EC2 实例以用作 Apache Kafka 客户端计算机。第二个任务是在计算机上安装 Java 和 Apache Kafka 工具。
创建客户端计算机
通过以下网址打开 Amazon EC2 控制台:https://console.aws.amazon.com/ec2/
。 选择 Launch instance (启动实例)。
选择第一个Select按钮。
选择 Next:。配置实例详细信息.
适用于网络,选择无服务器群集的Virtual Private Cloud (VPC)。这是基于 Amazon VPC 服务的 VPC,您在创建集群后保存了其 ID。
适用于子网中,选择创建集群后保存其 ID 的子网。
-
对于 IAM role (IAM 角色),选择
msk-serverless-tutorial
。 -
选择 Next:。添加存储.
-
选择 Next:。添加标签.
-
选择添加标签,然后在下面密钥输入
Name
在下值输入msk-serverless-tutorial
. -
选择 Next:。配置安全组.
-
选择标签为的按钮选择选择现有安全组.
-
在安全组的列表中,选择与集群关联的安全组。如果该安全组有允许流量从安全组到自身的入站规则,则此操作。这样的规则允许同一个安全组的成员相互通信。有关更多信息,请参阅 。安全组规则在 Amazon VPC 开发人员指南中。
-
选择查看并启动然后选择启动.
-
选择现有 key pair,或创建新的 key pair。
-
选择启动实例,然后选择查看实例.
-
选中表示此新创建的 Amazon EC2 实例的行中的复选框。从这一点开始,我们调用此实例这客户端机器.
-
选择Connect (连接)并按照说明操作以连接到客户端计算机。
在客户端计算机上设置 Apache Kafka 客户端工具
要安装 Java,请在客户端计算机上运行以下命令:
sudo yum -y install java-11
要获取创建主题和发送数据所需的 Apache Kafka 工具,请运行以下命令:
wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
tar -xzf kafka_2.12-2.8.1.tgz
为了使客户端计算机能够访问群集,您需要下载 Amazon MSK IAM JAR 文件。转至
kafka_2.12-2.8.1/libs
在目录中,运行以下命令:wget https://github.com/aws/aws-msk-iam-auth/releases/download/v1.1.1/aws-msk-iam-auth-1.1.1-all.jar
-
转至
kafka_2.12-2.8.1/bin
目录。复制以下属性设置并将其粘贴到新文件中。将该文件命名为client.properties
然后保存。security.protocol=SASL_SSL sasl.mechanism=AWS_MSK_IAM sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required; sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
下一步