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

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

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

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

创建客户端计算机

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

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

  3. 选择第一个Select按钮。

  4. 选择 Next:配置实例详细信息.

  5. 适用于网络,选择无服务器群集的Virtual Private Cloud (VPC)。这是基于 Amazon VPC 服务的 VPC,您在创建集群后保存了其 ID。

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

  7. 对于 IAM role (IAM 角色),选择 msk-serverless-tutorial

  8. 选择 Next:添加存储.

  9. 选择 Next:添加标签.

  10. 选择添加标签,然后在下面密钥输入Name在下输入msk-serverless-tutorial.

  11. 选择 Next:配置安全组.

  12. 选择标签为的按钮选择选择现有安全组.

  13. 在安全组的列表中,选择与集群关联的安全组。如果该安全组有允许流量从安全组到自身的入站规则,则此操作。这样的规则允许同一个安全组的成员相互通信。有关更多信息,请参阅 。安全组规则在 Amazon VPC 开发人员指南中。

  14. 选择查看并启动然后选择启动.

  15. 选择现有 key pair,或创建新的 key pair。

  16. 选择启动实例,然后选择查看实例.

  17. 选中表示此新创建的 Amazon EC2 实例的行中的复选框。从这一点开始,我们调用此实例这客户端机器.

  18. 选择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. 为了使客户端计算机能够访问群集,您需要下载 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
  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 主题