本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
步骤 5:生成和使用数据
在此步骤中,您将使用在先前步骤中创建的主题生成和使用数据。
生成和使用消息
-
运行以下命令以创建控制台生成器。
<path-to-your-kafka-installation>
/bin/kafka-console-producer.sh --broker-list $BS --producer.config client.properties --topic msk-serverless-tutorial -
输入所需的任何消息,然后按 Enter。重复执行此步骤两次或三次。每次输入一行并按 Enter 时,该行会作为单独的消息发送到集群。
-
将与客户端计算机的连接保持打开状态,然后在新窗口中打开与该计算机的第二个单独连接。
-
使用客户端计算机的第二个连接,通过以下命令创建控制台使用器。将
my-endpoint
替换为您在创建集群后保存的引导服务器字符串。<path-to-your-kafka-installation>
/bin/kafka-console-consumer.sh --bootstrap-servermy-endpoint
--consumer.config client.properties --topic msk-serverless-tutorial --from-beginning您开始看到之前使用控制台生成器命令时输入的消息。
-
在生成器窗口中输入更多消息,并观察消息显示在使用器窗口中。
下一步