搜索

3.2. 在使用 loadbalancer 类型监听程序时验证代理

download PDF

在通过本地代理运行 Kafka producer 和消费者时,验证代理是否正常工作。

  1. 使用 loadbalancer 地址从代理生成消息:

    通过代理生成消息

    kafka-console-producer \
    --bootstrap-server <load_balancer_address>:9092 \
    --topic my-topic

  2. 使用交互式 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

  3. 使用代理的消息来自动解密它们:

    直接从 Kafka 集群使用消息

     kafka-console-consumer \
     --bootstrap-server <load_balancer_address>:9092 \
     --topic my-topic \
     --from-beginning \
     --timeout-ms 10000

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.