Я учусь использовать 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
Я нашел ответ на официальном сайте.
Опция zookeeper устарела, вместо нее используйте --bootstrap-server.
Теперь это работает:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
Для пользователей Windows использовать
bin/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
Для окон
Для запуска зоопарка
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