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

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

第 3 步:创建主题

在此步骤中开始使用亚马逊 MSK,你在客户端计算机上安装 Apache Kafka 客户端库和工具,然后创建一个主题。

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

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

  2. 在导航窗格中,选择 Instances (实例)。然后选中您在中创建的客户端计算机名称旁边的复选框第 2 步:创建客户端计算机.

  3. 选择 Actions (操作),然后选择 Connect (连接)。按照控制台中的说明连接到客户端计算机。

  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. 转到ka_2.12-2.6.2目录。

  8. 在以下位置打开 Amazon MSK 控制台https://console.amazonaws.cn/msk/.

  9. 等待集群的状态变为处于活动状态. 这可能需要花几分钟的时间。状态变为之后处于活动状态,请选择集群名称。这将带您进入包含集群摘要的页面。

  10. 选择查看客户信息.

  11. 复制用于明文身份验证的连接字符串。

  12. 运行以下命令,替换BootstrapServerString使用您在上一步中获得的连接字符串。

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server BootstrapServerString --replication-factor 3 --partitions 1 --topic MSKTutorialTopic

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

下一步

第 4 步:生成和使用数据