本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
步骤 5:生成和使用数据
在开始使用 Amazon MSK 的此步骤中,生成和使用数据。
生成和使用消息
-
运行以下命令以启动控制台生成器。
$KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic
MSKTutorialTopic
-
输入所需的任何消息,然后按 Enter。重复执行此步骤两次或三次。每次输入一行并按 Enter 时,该行会作为单独的消息发送到您的 Apache Kafka 集群。
-
将与客户端计算机的连接保持打开状态,然后在新窗口中打开与该计算机的第二个单独连接。由于这是一个新会话,所以请再次设置
KAFKA_ROOT
和BOOTSTRAP_SERVER
环境变量。有关如何设置这些环境变量的信息,请参阅在客户端计算机上创建主题。 -
使用与客户端计算机的第二个连接字符串运行以下命令以创建控制台使用者。
$KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic
MSKTutorialTopic
--from-beginning当你使用控制台生产者命令时,你应该会开始看到之前输入的消息。
-
在生成器窗口中输入更多消息,并观察消息显示在使用器窗口中。
下一步
第 6 步:使用亚马逊 CloudWatch 查看亚马逊 MSK 指标