Как установить zookeeper ch root path при подключении к кафке с Golang?

Question

С 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?)

Что я должен делать?

Answer 1

Когда вы указываете Zookeeper ch root, он используется Kafka для хранения всех своих метаданных в Zookeeper.

Kafka Consumer не подключается к Zookeeper, он подключается только к Kafka. Вам необходимо указать серверы Kafka bootstrap в конфигурации своего потребителя.

В вашем примере похоже, что вы передаете URL Zookeeper своему потребителю, и поэтому он не работает.