如何使用Sarama Go客户端连接ZooKeeper？连接失败求助

问题背景 #

使用Sarama v1.38.0客户端连接Confluent Kafka 0.10.2.1集群，代码指定bootstrap servers为localhost:9092，调用NewClusterAdmin时出现报错：

kafka: client has run out of available brokers to talk to: EOF

用户误以为是ZooKeeper连接问题，但实际代码并未直接连接ZooKeeper。

核心原因 #

Sarama v1.38.0版本过高，与Kafka 0.10.2.1存在严重版本兼容性问题。高版本Sarama不再支持Kafka 0.10.x系列的旧协议，导致客户端与broker无法完成握手，最终连接失败。

解决方案 #

1. 降低Sarama版本 #

将Sarama版本降级到兼容Kafka 0.10.2.1的版本，比如v1.20.0（该版本仍支持Kafka 0.10.x系列）。

2. 指定Kafka协议版本 #

如果暂时无法降级版本，可在Sarama配置中强制指定与Kafka集群匹配的协议版本，确保客户端使用老协议通信：

config := kafka.NewConfig()
// 指定与Kafka集群一致的版本
config.Version = kafka.V0_10_2_1
broker := []string{"localhost:9092"}
kafkaClient, err := kafka.NewClusterAdmin(broker, config)

3. 检查Kafka Broker配置 #

确认Kafka broker的advertised.listeners配置正确，确保localhost:9092是客户端可以正常访问的地址。如果broker部署在远程机器，需替换为对应的IP或域名。

4. 澄清ZooKeeper连接误区 #

Sarama作为现代Kafka客户端，操作集群（如ClusterAdmin）无需直接连接ZooKeeper，所有通信都是通过Kafka broker完成的。当前报错与ZooKeeper无关，无需额外配置ZooKeeper连接信息。

内容的提问来源于stack exchange，提问作者Deepak Mourya