0
点赞
收藏
分享

微信扫一扫

Kafka Windows运行错误:创建消费者报错 consumer zookeeper is not a recognized option


出现该错,不用修改任何配置文件,原因为: 当前使用的 创建消费者命令 与 安装的kafka版本不一致,因为kafka在0.9版本之后,使用创建的kafka 消费者命令已经变了。

 

例如,我安装的是kafka 2.1.1版本, 创建消费者consumer 应该如下:

进入kafka安装目录, 运行命令:

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testJc --from-beginning

如:

Kafka Windows运行错误:创建消费者报错  consumer zookeeper is not a recognized option_consumer

或者进入到windows目录:

 .\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testJc

PS : 创建主题:

进入kafka安装目录, 运行命令:

bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic testJc

 

如: 

 

Kafka Windows运行错误:创建消费者报错  consumer zookeeper is not a recognized option_producer_02

 

或者进入到windows目录下:

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test098

Kafka Windows运行错误:创建消费者报错  consumer zookeeper is not a recognized option_Windows_03

 

 

创建生产者 producer:

进入kafka安装目录, 运行命令:

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic testJc

如:

Kafka Windows运行错误:创建消费者报错  consumer zookeeper is not a recognized option_consumer_04

然后输入需要推送的消息,就可看到监听同一个主题的消费者能成功收到消息:

如:

Kafka Windows运行错误:创建消费者报错  consumer zookeeper is not a recognized option_consumer_05

举报

相关推荐

0 条评论