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

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

第 3 步:创建主题

在这一步开始使用 Amazon MSK,您将在客户端计算机上安装 Apache Kafka 客户端库和工具,然后创建主题。

在客户端计算机上创建主题

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

  2. 在导航窗格中,选择实例,然后选择MSK TorutialClient选中旁边的复选框。

  3. 选择 Actions (操作),然后选择 Connect (连接)。按照说明进行操作以连接到客户端计算机MSK TorutialClient.

  4. 通过运行以下命令在客户端计算机上安装 Java:

    sudo yum install java-1.8.0
  5. 运行以下命令以下载 Apache Kafka。

    wget https://archive.apache.org/dist/kafka/2.6.2/kafka_2.12-2.6.2.tgz
    注意

    如果您希望使用此命令中使用的镜像站点之外的镜像站点,则可在 Apache 网站上选择其他镜像站点。

  6. 在上一步中将 TAR 文件下载到的目录中运行以下命令。

    tar -xzf kafka_2.12-2.6.2.tgz
  7. 转至kafka_2.12-2.6.2目录。

  8. 从打开 Amazon MSK 控制台https://console.amazonaws.cn/msk/.

  9. 等待状态MSK Torial集群成为处于活动状态. 这可能需要花几分钟的时间。状态变为之后处于活动状态中,选择集群名称。此操作将带您进入一个页面,您可以在其中看到集群摘要。

  10. 选择查看客户信息.

  11. 复制私有终端节点以进行明文身份验证和 Apache ZooKeeper 连接字符串(也适用于明文通信)。

  12. 运行以下命令,替换:ZookeeperConnectString用你在之前的指令中获得的字符串。

    bin/kafka-topics.sh --create --zookeeper ZookeeperConnectString --replication-factor 3 --partitions 1 --topic MSKTutorialTopic

    如果此命令成功,您将看到以下消息:Created topic MSKTutorialTopic.

下一步

第 4 步:生成和使用数据