go - 如何连接到使用 confluent helm chart 安装的 kafka

Question

我有一个托管在天蓝色云上的 Kubernetes 集群。我使用下面的 Helm chart https://github.com/confluentinc/cp-helm-charts/tree/master/charts/cp-kafka 安装了 kafka 资源.这个 helm chart 成功部署了 zoopkeeper pod 和 broker pod 等。现在我想编写一个基于 golang 的应用程序，它与安装在我的 kubernetes 集群上的任何 kafka 代理连接，并创建一个新的生产者并发布消息。任何帮助将不胜感激。

Answer 1

您可以在 bootstrap.servers 中使用以下字符串与代理通信 <helm-release-name>-cp-kafka-headless.<namespace>:9092或作为融合 Helm chart 的一部分创建的引导服务 <helm-release-name>-cp-kafka .当你点击这个服务时，它会第一次随机到达任何一个broker，并获取所有通过zookeeper同步的元数据信息。
随后的请求将根据元数据中的信息向各个代理发出。