第 3 步:创建客户端计算机 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

第 3 步:创建客户端计算机

在步骤中,您将执行下面两个任务。第一个任务是创建一个用作 Apache Kafka 客户端计算机的 Amazon EC2 实例。第二个任务是在机器上安装 Java 和 Apache Kafka 工具。

创建客户端计算机

  1. 通过以下网址打开 Amazon EC2 控制台:https://console.aws.amazon.com/ec2/

  2. 选择 Launch instance (启动实例)

  3. 输入 Desption名称用于您的客户端计算机,例如msk-serverless-tutorial-client.

  4. 离开亚马逊 Linux 2 AMI (HVM)-内核 5.10, 固态硬盘类型)-内核 5.10,已选择Amazon 系统映像 (AMI) 类型.

  5. 离开t2.micro已选择实例类型。

  6. UNDER密钥对(登录),选择创建新key pair. EnterMSKServerlessKeyPair为了密钥对名称. 然后,选择 Download Key Pair (下载密钥对)。此外,您还可使用现有密钥对。

  7. 适用于Network settings (网络设置),选择编辑.

  8. UNDERVPC中,输入无服务器集群的虚拟私有云 (VPC) 的 ID。这是基于 Amazon VPC 服务的 VPC,您在创建集群后保存了该 VPC 的 ID。

  9. 适用于子网,选择您在创建集群后保存其 ID 的子网。

  10. 适用于防火墙(安全组)中,选择与集群关联的安全组。如果该安全组具有允许从安全组到自身的流量的入站规则,则此值有效。有了这样的规则,同一个安全组的成员可以相互通信。有关更多信息,请参阅 。安全组规则(在 Amazon VPC 开发人员指南中)。

  11. 展开高级详细信息部分并选择您在中创建的 IAM 角色第 2 步:创建 IAM 角色.

  12. 选择启动

  13. 在左侧导航窗格中,选择 Instances (实例)。然后选中代表您新创建的 Amazon EC2 实例的行中的复选框。从现在开始,我们将这个实例称为客户端计算机.

  14. 选择Connect (连接),然后按照说明执行操作,连接到客户端计算机。

在客户端计算机上设置 Apache Kafka 客户端工具

  1. 要安装 Java,请在客户端计算机上运行以下命令:

    sudo yum -y install java-11
  2. 要获取创建主题和发送数据所需的 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
  3. 转至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
  4. 转至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

下一步

第 4 步:创建 Apache Kafka 主题