步骤 5:生成和使用数据 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

步骤 5:生成和使用数据

开始使用 Amazon MSK 的此步骤中,您需生成和使用数据。

生成和使用消息
  1. 运行以下命令以启动控制台生成器。BootstrapServerString替换为您在创建主题中获得的纯文本连接字符串。有关如何检索此连接字符串的说明,请参阅 Getting the bootstrap brokers for an Amazon MSK cluster

    <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapServerString --producer.config client.properties --topic MSKTutorialTopic
  2. 输入所需的任何消息,然后按 Enter。重复执行此步骤两次或三次。每次输入一行并按 Enter 时,该行会作为单独的消息发送到您的 Apache Kafka 集群。

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

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

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

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

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

下一步

第 6 步:使用亚马逊 CloudWatch 查看亚马逊 MSK 指标