3.2. 在使用 loadbalancer 类型监听程序时验证代理
在通过本地代理运行 Kafka producer 和消费者时,验证代理是否正常工作。
使用 loadbalancer 地址从代理生成消息:
通过代理生成消息
kafka-console-producer \ --bootstrap-server <load_balancer_address>:9092 \ --topic my-topic
kafka-console-producer \ --bootstrap-server <load_balancer_address>:9092 \ --topic my-topicCopy to Clipboard Copied! Toggle word wrap Toggle overflow 使用交互式 pod 容器直接从 Kafka 集群使用消息来显示它们已被加密:
直接从 Kafka 集群使用消息
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 使用代理的消息来自动解密它们:
直接从 Kafka 集群使用消息
kafka-console-consumer \ --bootstrap-server <load_balancer_address>:9092 \ --topic my-topic \ --from-beginning \ --timeout-ms 10000
kafka-console-consumer \ --bootstrap-server <load_balancer_address>:9092 \ --topic my-topic \ --from-beginning \ --timeout-ms 10000Copy to Clipboard Copied! Toggle word wrap Toggle overflow