如何连接到使用 confluent helm chart 安装的 kafka答案

【问题标题】：How to connect to kafka installed using confluent helm chart如何连接到使用 confluent helm chart 安装的 kafka
【发布时间】：2020-06-08 04:20:15
【问题描述】：

我有一个托管在 Azure 云上的 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 代理连接，并创建一个新的生产者并发布消息。任何帮助将不胜感激。

【问题讨论】：

请出示你目前为止的 Go 代码。

标签： go kubernetes apache-kafka

【解决方案1】：

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

后续请求将根据元数据中的信息向各个代理发出。

【讨论】：

【解决方案2】：

您可以将 Golang 代码部署在容器中，在 k8s 中，然后将 bootstrap.servers 设置为 Kafka 部署的服务名称，最好通过环境变量进行

【讨论】：