第 6 章 设置对 Kafka 集群的客户端访问权限

部署 AMQ Streams 后,本节中的步骤解释了如何:

  • 部署示例制作者和消费者客户端,您可以使用它们来验证您的部署
  • 设置对 Kafka 集群的外部客户端访问

    为 OpenShift 外部的客户端设置 对 Kafka 集群的访问权限的步骤更为复杂,需要熟悉 OpenShift 中使用 AMQ Streams 指南 中所述的 Kafka 组件配置 流程

6.1. 部署示例客户端

此流程演示了如何使用您创建的 Kafka 集群发送和接收信息部署示例制作者和消费者客户端。

先决条件

  • Kafka 集群可供客户端使用。

流程

  1. 部署 Kafka 制作者.

    oc run kafka-producer -ti --image=registry.redhat.io/amq7/amq-streams-kafka-28-rhel7:1.8.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --broker-list cluster-name-kafka-bootstrap:9092 --topic my-topic
  2. 在运行制作者的控制台中键入消息。
  3. Enter 发送邮件。
  4. 部署 Kafka 用户。

    oc run kafka-consumer -ti --image=registry.redhat.io/amq7/amq-streams-kafka-28-rhel7:1.8.0 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server cluster-name-kafka-bootstrap:9092 --topic my-topic --from-beginning
  5. 确认您在使用者控制台中看到传入的消息。