本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
第6步: 生成和消耗数据
在开始使用 Amazon MSK 的此步骤中,您将生成和使用数据。
生成和使用消息
-
在本示例中,我们使用 JVM 信任存储与 MSK 集群通信。为此,请首先在客户端计算机上创建一个名为
/tmp
的文件夹。然后,前往bin
文件夹,并运行以下命令,替换JDKFolder
使用您的JDK文件夹的名称。例如,您实例中的 JDK 文件夹的名称可能是java-1.8.0-openjdk-1.8.0.201.b09-0.amzn2.x86_64
。cp /usr/lib/jvm/
JDKFolder
/jre/lib/security/cacerts /tmp/kafka.client.truststore.jks -
仍在客户端计算机上的 Apache Kafka 安装的
bin
文件夹中,创建一个名为client.properties
的文本文件,该文件包含以下内容。security.protocol=SSL ssl.truststore.location=/tmp/kafka.client.truststore.jks
-
运行以下命令,替换
ClusterArn
和Amazon资源名称(ARN)的 第3步: 创建 Amazon MSK 集群.aws kafka get-bootstrap-brokers --region us-east-1 --cluster-arn
ClusterArn
从命令的 JSON 结果中,保存与名为
"BootstrapBrokerStringTls"
的字符串关联的值,因为您需要在以下命令中使用它。 -
在中运行以下命令
bin
文件夹,替换BootstrapBrokerStringTls
使用您在运行上一个命令时获得的值。./kafka-console-producer.sh --broker-list
BootstrapBrokerStringTls
--producer.config client.properties --topic AWSKafkaTutorialTopic -
输入所需的任何消息,然后按 Enter。重复执行此步骤两次或三次。每次输入一行并按 Enter 时,该行会作为单独的消息发送到您的 Apache Kafka 集群。
-
将与客户端计算机的连接保持打开状态,然后在新窗口中打开与该计算机的第二个单独连接。
-
在以下命令中,替换
BootstrapBrokerStringTls
包含您之前保存的值。然后,转到bin
文件夹并使用与客户端计算机的第二个连接运行命令。./kafka-console-consumer.sh --bootstrap-server
BootstrapBrokerStringTls
--consumer.config client.properties --topic AWSKafkaTutorialTopic --from-beginning您开始看到之前使用控制台生成器命令时输入的消息。这些消息在传输时已进行 TLS 加密。
-
在生成器窗口中输入更多消息,并观察消息显示在使用器窗口中。
下一步
第7步: 使用 Amazon CloudWatch 到视图 Amazon MSK 指标