第 5 步：创建主题

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

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.