Apache Kafka: zookeeper is not a recognized option

При попытке запустить скрипт Apache Kafka в консоли потребителя получаем следующее сообщение об ошибке: "zookeeper is not a recognized option".

Table of Contents

Пример

./bin/kafka-console-consumer.sh --topic testTopic --zookeeper localhost:9092

1	./bin/kafka-console-consumer.sh --topic testTopic --zookeeper localhost:9092

zookeeper is not a recognized option
Option                                   Description
------                                   -----------
--bootstrap-server 
--consumer-property                            properties in the form key=value to
...
...

zookeeper is not a recognized option

Option Description

------ -----------

--bootstrap-server

--consumer-property properties in the form key=value to

...

Решение

В руководстве Apache Kafa QUICKSTART имеется решение, что в Kafka убрали опцию --zookeeper и заменили ее на новую --bootstrap-server .

Таким образом, новая команда будет выглядеть следующим образом:

./bin/kafka-console-consumer.sh --topic testTopic --bootstrap-server localhost:9092

1	./bin/kafka-console-consumer.sh --topic testTopic --bootstrap-server localhost:9092

Надеюсь, это поможет вам решить проблему с Kafka.