zookeeper не распознается при выполнении kafka-console-consumer.sh

Я учусь использовать kafka по этой ссылке(за исключением того, что я использую порт 2182 в zookeeper),

но это показывает:

зоопарк не является признанным вариантом

после выполнения:

sudo./bin/kafka-console-consumer.sh --topic test --zookeeper localhost:2182

Как это исправить?

Env:

kafka_2.11-2.1.0
zookeeper-3.4.10

Ответы

Ответ 1

Я нашел ответ на официальном сайте.

Опция zookeeper устарела, вместо нее используйте --bootstrap-server.

Теперь это работает:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

Ответ 2

Для пользователей Windows использовать

bin/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

Ответ 3

Для окон

Для запуска зоопарка

C:\kafka-2.12>.\bin\windows\zookeeper-server-start.bat .\config\server.properties

Для запуска Kafka Broker

C:\kafka-2.12>.\bin\windows\kafka-server-start.bat .\config\server.properties

Создать тему

C:\kafka-2.12\bin\windows>kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Начать продюсер

C:\kafka-2.12\bin\windows>kafka-console-producer.bat --broker-list localhost:9092 --topic test

Для создания потребителя

C:\kafka-2.12\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

Создание темы с несколькими разделами с коэффициентом репликации 1

C:\kafka-2.12\bin\windows>kafka-topics --zookeeper localhost:2181 --topic first_topic --create --partitions 3 --replication-factor 1

Получить список тем, созданных в системе

C:\kafka-2.12\bin\windows>kafka-topics --zookeeper localhost:2181 --list