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

流程

1. 部署 Kafka producer。

   本例部署一个 Kafka 生成者，它连接到 Kafka 集群 my-cluster。

   名为 my-topic 的主题被创建。

   将 Kafka producer 部署到 OpenShift

   oc run kafka-producer -ti --image=registry.redhat.io/amq-streams/kafka-38-rhel9:2.8.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --topic my-topic

   Copy to Clipboard Toggle word wrap

2. 在运行制作者的控制台中输入消息。
3. 按 Enter 发送邮件。

4. 部署 Kafka 使用者。

   消费者应使用在 Kafka 集群 my-cluster 中生成到 my-topic 的消息。

   将 Kafka 使用者部署到 OpenShift

   oc run kafka-consumer -ti --image=registry.redhat.io/amq-streams/kafka-38-rhel9:2.8.0 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --topic my-topic --from-beginning

   Copy to Clipboard Toggle word wrap

5. 确认您在使用者控制台中看到传入的信息。