2.6. 从主题发送和接收消息
您可以通过从 my-topic 发送和接收集群外的信息来测试 AMQ Streams 安装。
使用终端在本地机器上运行 Kafka 制作者和使用者。
先决条件
- 确保 OpenShift 集群上安装了 AMQ Streams。
- zookeeper 和 Kafka 必须正在运行才能发送和接收信息。
- 您需要 集群 CA 证书才能访问集群。
- 您必须能够从 AMQ Streams 下载网站访问最新版本的红帽 AMQ Streams 存档。
流程
从 AMQ Streams 下载 网站下载最新版本的 AMQ Streams 归档(
amq-streams-x.y.z-bin.zip)。将 文件解压缩到任何目标。
打开一个终端，再启动 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- 在运行制作者的控制台中键入您的消息。
- 按 Enter 发送邮件。
打开一个新的终端标签页或窗口，启动 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- 确认您在使用者控制台中看到传入的消息。
- 按 Crtl+C 退出 Kafka 控制台制作者和使用者。
