2.6. 从主题发送和接收消息

您可以通过从 my-topic 发送和接收集群外的信息来测试 AMQ Streams 安装。

使用终端在本地机器上运行 Kafka 制作者和使用者。

先决条件

流程

  1. 从 AMQ Streams 下载 网站下载最新版本的 AMQ Streams 归档( amq-streams-x.y.z-bin.zip)。

    将 文件解压缩到任何目标。

  2. 打开一个终端,再启动 Kafka 控制台制作者,主题为 my-topic 以及 TLS 的身份验证属性:

    bin/kafka-console-producer.sh --broker-list ROUTE-ADDRESS:443 --producer-property security.protocol=SSL --producer-property ssl.truststore.password=password --producer-property ssl.truststore.location=./client.truststore.jks --topic my-topic
  3. 在运行制作者的控制台中键入您的消息。
  4. 按 Enter 发送邮件。
  5. 打开一个新的终端标签页或窗口,启动 Kafka 控制台消费者以接收消息:

    bin/kafka-console-consumer.sh --bootstrap-server ROUTE-ADDRESS:443 --consumer-property security.protocol=SSL --consumer-property ssl.truststore.password=password --consumer-property ssl.truststore.location=./client.truststore.jks --topic my-topic --from-beginning
  6. 确认您在使用者控制台中看到传入的消息。
  7. 按 Crtl+C 退出 Kafka 控制台制作者和使用者。