本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
向 MSK 集群发送数据
在此步骤中,您将数据发送到之前创建的 Apache Kafka 主题,然后在目标 S3 存储桶中查找相同的数据。
向 MSK 集群发送数据
-
在客户端实例上的 Apache Kafka 安装
bin
文件夹中,创建一个名为client.properties
的文本文件,该文件包含以下内容。security.protocol=SASL_SSL sasl.mechanism=AWS_MSK_IAM
-
运行以下命令以创建控制台生成器。将
BootstrapBrokerString
替换为您运行上一条命令时获得的值。<path-to-your-kafka-installation>
/bin/kafka-console-producer.sh --broker-listBootstrapBrokerString
--producer.config client.properties --topic mkc-tutorial-topic -
输入所需的任何消息,然后按 Enter。重复执行此步骤两次或三次。每次输入一行并按 Enter 时,该行会作为单独的消息发送到您的 Apache Kafka 集群。
查看目标 Amazon S3 存储桶,查找您在上一步中发送的消息。