执行kafka-console-consumer.sh时,zookeeper不是公认的选项

Question

我从这个链接学习如何使用kafka (除了我在zookeeper中使用端口2182),

但它显示:

zookeeper不是公认的选择

执行后:

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

我做了一些搜索,似乎有一个未答复的重复问题,但它已被删除.

有人知道怎么解决吗？

ENV:

kafka_2.11-2.1.0
zookeeper-3.4.10

Answer 1

我在官方网站上找到了答案.

选项zookeeper已弃用,请--bootstrap-server改用.

它现在有效:

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

Answer 2

窗户用

启动动物园管理员

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

获取系统中创建的topic的描述

C:\kafka-2.12\bin\windows>kafka-topics.bat --describe --zookeeper localhost:2181 --topic test

删除系统中创建的主题测试

C:\kafka-2.12\bin\windows>kafka-run-class.bat kafka.admin.TopicCommand --delete --topic test --zookeeper localhost:2181

从系统中创建的主题测试开始读取消息（版本> 2.0）

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

Answer 3

对于Windows用户使用

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