go之使用Golang连接kafka时如何设置zookeeper chroot路径

使用 Kafka Tool，我的配置如下:

Zookeeper Host:192.168.60.97 
Zookeeper Port:2181 
chroot path: /kafka1 

但是当我尝试这个

consumer, err = sarama.NewConsumer([]string{"192.168.60.97:2181:/kafka1"}, nil) 

我总是有

kafka: client has run out of available brokers to talk to (Is your cluster reachable?) 

我应该做什么？

请您参考如下方法:

当您指定 Zookeeper chroot 时，Kafka 将使用它在 Zookeeper 中存储其所有元数据。

Kafka Consumer不连接到Zookeeper，它只连接到Kafka。您需要在消费者配置中指定 Kafka 引导服务器。

在您的示例中，您似乎正在将 Zookeeper URL 传递给您的使用者，因此它不起作用。