问题描述
我有一个用于消费和生产的多节点 Kafka 集群。
在我的应用程序中，我使用 confluent-kafka-go(1.6.1) 创建生产者和消费者。当我生成和使用消息时，一切都很好。 这就是我配置引导服务器列表的方式
"bootstrap.servers":"localhost:9092,localhost:9093,localhost:9094"
但是当我开始在 bootstrap.servers 中给出代理的 IP 地址并且如果第一个代理关闭的那一刻，似乎生产者反复失败创建告诉
Failed to initialize Producer ID: Local: Timed out
如果我删除了故障节点的 IP，生产和消费消息就会起作用。 如果在我创建生产者/消费者后代理关闭，它们可以通过切换到其他节点继续使用。
我应该如何配置 bootstrap.servers 以便使用可用节点创建生产者？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）