第6步: 生成和消耗数据

生成和使用消息

1. 在本示例中，我们使用 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

2. 仍在客户端计算机上的 Apache Kafka 安装的 bin 文件夹中，创建一个名为 client.properties 的文本文件，该文件包含以下内容。

   security.protocol=SSL
   ssl.truststore.location=/tmp/kafka.client.truststore.jks

3. 运行以下命令,替换 ClusterArn 和Amazon资源名称(ARN)的 第3步: 创建 Amazon MSK 集群.

   aws kafka get-bootstrap-brokers --region us-east-1 --cluster-arn ClusterArn

   从命令的 JSON 结果中，保存与名为 "BootstrapBrokerStringTls" 的字符串关联的值，因为您需要在以下命令中使用它。

4. 在中运行以下命令 bin 文件夹,替换 BootstrapBrokerStringTls 使用您在运行上一个命令时获得的值。

   ./kafka-console-producer.sh --broker-list BootstrapBrokerStringTls --producer.config client.properties --topic AWSKafkaTutorialTopic

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

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

7. 在以下命令中,替换 BootstrapBrokerStringTls 包含您之前保存的值。然后，转到 bin 文件夹并使用与客户端计算机的第二个连接运行命令。

   ./kafka-console-consumer.sh --bootstrap-server BootstrapBrokerStringTls --consumer.config client.properties --topic AWSKafkaTutorialTopic --from-beginning

   您开始看到之前使用控制台生成器命令时输入的消息。这些消息在传输时已进行 TLS 加密。

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