第 4 步：生成和使用数据

生成和使用消息

1. 转到客户端计算机上安装的 Apache Kafka 文件bin夹，然后创建一个包含以下内容client.properties的名字的文本文件。

   security.protocol=PLAINTEXT

2. 运行以下命令以启动控制台生成器。BootstrapServerString用您在中获得的纯文本连接字符串进行替换步骤 3：创建主题。有关如何检索此连接字符串的说明，请参阅获取一个 Amazon MSK 集群的引导代理存储。

   <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapServerString --producer.config client.properties --topic MSKTutorialTopic

3. 输入所需的任何消息，然后按 Enter。重复执行此步骤两次或三次。每次输入一行并按 Enter 时，该行会作为单独的消息发送到您的 Apache Kafka 集群。

4. 将与客户端计算机的连接保持打开状态，然后在新窗口中打开与该计算机的第二个单独连接。

5. 在以下命令中，BootstrapServerString替换为之前保存的纯文本连接字符串。然后，要创建控制台使用者，请使用与客户端计算机的第二个连接运行以下命令。

   <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapServerString --consumer.config client.properties --topic MSKTutorialTopic --from-beginning

   您开始看到之前使用控制台生成器命令时输入的消息。

6. 在生成器窗口中输入更多消息，并观察消息显示在使用器窗口中。