本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
第 3 步:创建主题
在这一步开始使用 Amazon MSK,您将在客户端计算机上安装 Apache Kafka 客户端库和工具,然后创建主题。
在客户端计算机上创建主题
通过以下网址打开 Amazon EC2 控制台:https://console.aws.amazon.com/ec2/
。 -
在导航窗格中,选择实例,然后选择MSK TorutialClient选中旁边的复选框。
-
选择 Actions (操作),然后选择 Connect (连接)。按照说明进行操作以连接到客户端计算机MSK TorutialClient.
-
通过运行以下命令在客户端计算机上安装 Java:
sudo yum install java-1.8.0
-
运行以下命令以下载 Apache Kafka。
wget https://archive.apache.org/dist/kafka/2.6.2/kafka_2.12-2.6.2.tgz
注意 如果您希望使用此命令中使用的镜像站点之外的镜像站点,则可在 Apache
网站上选择其他镜像站点。 -
在上一步中将 TAR 文件下载到的目录中运行以下命令。
tar -xzf kafka_2.12-2.6.2.tgz
-
转至kafka_2.12-2.6.2目录。
-
从打开 Amazon MSK 控制台https://console.amazonaws.cn/msk/
. 等待状态MSK Torial集群成为处于活动状态. 这可能需要花几分钟的时间。状态变为之后处于活动状态中,选择集群名称。此操作将带您进入一个页面,您可以在其中看到集群摘要。
选择查看客户信息.
复制私有终端节点以进行明文身份验证和 Apache ZooKeeper 连接字符串(也适用于明文通信)。
-
运行以下命令,替换:
ZookeeperConnectString
用你在之前的指令中获得的字符串。bin/kafka-topics.sh --create --zookeeper
ZookeeperConnectString
--replication-factor 3 --partitions 1 --topic MSKTutorialTopic如果此命令成功,您将看到以下消息:
Created topic MSKTutorialTopic.
下一步