向 MSK 集群发送数据 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

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

向 MSK 集群发送数据

在此步骤中,您将数据发送到之前创建的 Apache Kafka 主题,然后在目标 S3 存储桶中查找相同的数据。

向 MSK 集群发送数据
  1. 在客户端实例上的 Apache Kafka 安装 bin 文件夹中,创建一个名为 client.properties 的文本文件,该文件包含以下内容。

    security.protocol=SASL_SSL sasl.mechanism=AWS_MSK_IAM
  2. 运行以下命令以创建控制台生成器。将BootstrapBrokerString替换为您运行上一条命令时获得的值。

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

  4. 查看目标 Amazon S3 存储桶,查找您在上一步中发送的消息。