本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
第 3 步:创建客户端计算机
在步骤中,您将执行下面两个任务。第一个任务是创建一个用作 Apache Kafka 客户端计算机的 Amazon EC2 实例。第二个任务是在机器上安装 Java 和 Apache Kafka 工具。
创建客户端计算机
通过以下网址打开 Amazon EC2 控制台:https://console.aws.amazon.com/ec2/
。 选择 Launch instance (启动实例)。
输入 Desption名称用于您的客户端计算机,例如
msk-serverless-tutorial-client.-
离开亚马逊 Linux 2 AMI (HVM)-内核 5.10, 固态硬盘类型)-内核 5.10,已选择Amazon 系统映像 (AMI) 类型.
-
离开t2.micro已选择实例类型。
-
UNDER密钥对(登录),选择创建新key pair. Enter
MSKServerlessKeyPair为了密钥对名称. 然后,选择 Download Key Pair (下载密钥对)。此外,您还可使用现有密钥对。 -
适用于Network settings (网络设置),选择编辑.
-
UNDERVPC中,输入无服务器集群的虚拟私有云 (VPC) 的 ID。这是基于 Amazon VPC 服务的 VPC,您在创建集群后保存了该 VPC 的 ID。
适用于子网,选择您在创建集群后保存其 ID 的子网。
-
适用于防火墙(安全组)中,选择与集群关联的安全组。如果该安全组具有允许从安全组到自身的流量的入站规则,则此值有效。有了这样的规则,同一个安全组的成员可以相互通信。有关更多信息,请参阅 。安全组规则(在 Amazon VPC 开发人员指南中)。
-
展开高级详细信息部分并选择您在中创建的 IAM 角色第 2 步:创建 IAM 角色.
-
选择启动。
-
在左侧导航窗格中,选择 Instances (实例)。然后选中代表您新创建的 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.tgztar -xzf kafka_2.12-2.8.1.tgz转至
kafka_2.12-2.8.1/libs目录,然后运行以下命令以下载 Amazon MSK IAM JAR 文件。借助 Amazon MSK IAM JAR,客户端计算机可以访问集群。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
下一步