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

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

第 5 步:创建主题

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

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

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

  2. 在导航窗格中,选择 Instances (实例),然后通过选中 AWSKafkaTutorialClient 旁边的复选框来选择它。

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

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

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

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

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

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

    tar -xzf kafka_2.12-2.2.1.tgz
  7. 转到 kafka_2.12-2.2.1 目录。

  8. 创建集群可能需要花费几分钟的时间。要了解您创建的集群是否已就绪,请运行以下命令,并将 ClusterArn 替换为您在第 3 步:创建亚马逊 MSK 集群结束时获取的 Amazon 资源名称 (ARN)。

    aws kafka describe-cluster --region us-east-1 --cluster-arn "ClusterArn"

    运行此命令的结果如以下 JSON 所示:

    { "ClusterInfo": { "BrokerNodeGroupInfo": { "BrokerAZDistribution": "DEFAULT", "ClientSubnets": [ "subnet-0d44a1567c2ce409a", "subnet-051201cac65561565", "subnet-08b4eceb2bd3bd8c2" ], "InstanceType": "kafka.m5.large", "SecurityGroups": [ "sg-041e78b0a8ba7f834" ], "StorageInfo": { "EbsStorageInfo": { "VolumeSize": 1000 } } }, "ClusterArn": "...", "ClusterName": "AWSKafkaTutorialCluster", "CreationTime": "2018-11-06T01:36:57.451Z", "CurrentBrokerSoftwareInfo": { "KafkaVersion": "2.2.1" }, "CurrentVersion": "K3UN6WX5RRO2AG", "EncryptionInfo": { "EncryptionAtRest": { "DataVolumeKMSKeyId": "arn:aws:kms:us-east-1:012345678901:key/a7de6539-7d2e-4e71-a279-aaaa5555878" } }, "EnhancedMonitoring": "DEFAULT", "NumberOfBrokerNodes": 3, "State": "CREATING" } }

    如果命令的输出显示集群的状态仍为 CREATING,请等待几分钟,然后再次运行该命令。继续每隔几分钟运行一次此命令,直到状态变为 ACTIVE 为止。当状态为 ACTIVE 时,此 describe-cluster 命令的输出会包含一个名为 ZookeeperConnectString 的附加键。复制与此键关联的整个值,因为您需要使用它在以下命令中创建 Apache Kafka 主题。

  9. 运行以下命令,并将 ZookeeperConnectString 替换为您在运行 describe-cluster 命令后保存的值。

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

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

下一步

第 6 步:生成和使用数据