使用 Golang 连接到 kafka 时如何设置 zookeeper chroot 路径？
How to set zookeeper chroot path when connect to kafka with Golang?
使用 Kafka 工具，我的配置如下：
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 bootstrap 服务器。
在您的示例中，您似乎正在将 Zookeeper URL 传递给您的消费者，因此它不起作用的原因。
使用 Kafka 工具，我的配置如下：
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 bootstrap 服务器。
在您的示例中，您似乎正在将 Zookeeper URL 传递给您的消费者，因此它不起作用的原因。