如何连接到使用 Confluence Helm Chart 安装的 kafka

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《如何连接到使用 Confluence Helm Chart 安装的 kafka》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

我有一个托管在 Azure 云上的 Kubernetes 集群。我已经使用下面的 helm 图表安装了 kafka 资源 https://github.com/confluenceinc/cp-helm-charts/tree/master/charts/cp-kafka。这个 Helm Chart 成功部署了 Zoopkeeper Pod 和 Broker Pod 等。现在我想编写一个基于 Golang 的应用程序，它与安装在我的 kubernetes 集群上的任何 Kafka Broker 连接，并创建一个新的生产者并发布消息。任何帮助将不胜感激。

解决方案

您可以在 bootstrap.servers 中使用以下字符串与代理 -cp-kafka-headless.:9092 或作为合流 helm 图表 。当您使用此服务时，它会在第一次随机访问任何代理并获取通过zookeeper同步的所有元数据信息。