第6步: 生成和消耗数据 - Amazon Managed Streaming for Apache Kafka
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

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

第6步: 生成和消耗数据

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

生成和使用消息

  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. 在生成器窗口中输入更多消息,并观察消息显示在使用器窗口中。

下一步

第7步: 使用 Amazon CloudWatch 到视图 Amazon MSK 指标