3.2. 在使用 loadbalancer 类型监听程序时验证代理
在通过本地代理运行 Kafka producer 和消费者时,验证代理是否正常工作。
使用 loadbalancer 地址从代理生成消息:
通过代理生成消息
kafka-console-producer \ --bootstrap-server <load_balancer_address>:9092 \ --topic my-topic
使用交互式 pod 容器直接从 Kafka 集群使用消息来显示它们已被加密:
直接从 Kafka 集群使用消息
oc run -n my-cluster -ti cluster-consumer \ --image=registry.redhat.io/amq-streams/kafka-37-rhel9:2.7.0 \ --rm=true \ --restart=Never -- ./bin/kafka-console-consumer.sh \ --bootstrap-server my-cluster-kafka-bootstrap:9092 \ --topic my-topic \ --from-beginning \ --timeout-ms 10000
使用代理的消息来自动解密它们:
直接从 Kafka 集群使用消息
kafka-console-consumer \ --bootstrap-server <load_balancer_address>:9092 \ --topic my-topic \ --from-beginning \ --timeout-ms 10000