Zookeeper / Kafka: брокеры Kafka не обнаружены в кластере Zookeeper (Kafka работает нормально)

Question

Я создал кластер Kafka с 4 узлами, кластер Zookeeper с 3 узлами. Кафка работает на v2.4.0 и Zookeeper на v3.5.6. Кластер Kafka успешно запускается и может успешно установить sh соединение с одним из узлов в кластере Zookeeper (проверенные журналы kafka), к которому я могу создать / список тем, производить / потреблять сообщения от этого кластера, когда я использую опцию --bootstrap-server. Но после использования опции --zookeeper все начинает давать сбой.

Я также пытался составить список брокеров kafka, используя утилиту zkCli.sh, которая поставляется вместе с автономной установкой zookeeper, но я получил пустой список [].

Используемая команда:

./zkCli.sh -server localhost:2181
ls /brokers/ids

Хотя после использования echo stat | nc localhost 2181 я вижу список брокеров кафки, напечатанных на консоли.

Я немного запутался здесь о том, как работает мой кластер kafka, даже если запросы, направленные на мой кластер zookeeper, терпят неудачу, и тот факт, что я не мог перечислить активных брокеров kafka с помощью утилиты zkCli.

Любые идеи по этому вопросу высоко ценятся .

Answer 1

Проверьте значение Zookeeper ch root path. Если он задан, то следует использовать следующую команду:

./zkCli.sh -server localhost:2181/zookeeper_chroot_path
ls /brokers/ids

Между localhost: 2181 и zookeeper_chroot_path

не должно быть пробела.

Answer 2

Эта проблема часто возникает из-за лишних пробелов в командной строке при использовании обработчика командной строки zookeeper. Просто обратите внимание на то же самое.