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

Question

我有一个托管在天蓝色云上的 Kubernetes 集群。我已经使用下面的 helm 图表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作为 confluent helm chart 的一部分创建的代理或引导服务进行通信<helm-release-name>-cp-kafka。当你点击这个服务时，它会第一次随机到达任何一个brokers，并获取所有通过zookeeper同步的元数据信息。随后的请求将根据元数据中的信息向各个代理发出。

Answer 2

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