console-consumer.sh时,java-zookeeper不是可识别的选项

vq8itlhq  于 2021-06-07  发布在  Kafka
关注(0)|答案(3)|浏览(340)

我正在学习如何从这个链接使用Kafka(除了我在zookeeper中使用端口2182),
但它表明:
zookeeper不是可识别的选项
执行后:
sudo./bin/kafka-console-consumer.sh—主题测试—zookeeperlocalhost:2182
如何修复?
环境:

kafka_2.11-2.1.0
zookeeper-3.4.10
qlfbtfca

qlfbtfca1#

供windows用户使用

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

gwbalxhn2#

我在官方网站上找到了答案:
期权 zookeeper 已弃用,请使用 --bootstrap-server 相反。
现在起作用了:

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

q3aa05253#

对于windows
启动zookeeper

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

启动Kafka经纪人

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

相关问题