kafka安装后命令测试创建消费者报错 zookeeper is not a recognized option

 创建消费者命令 ,并进行消费

 .\bin\windons\kafka-console-consumer.bat --zookeeper localhost:2181 --topic 主题名

通过此命名报如下错误: 

出现了上述图片问题,导致这个问题的原因,应该kafka版本较高的问题,0.90版本以后在启动的时候 --zookeeper是一个过时的方法,在0.90版本之后,最新的版本中,这种启动方式已经被删除了

启动命名更改为:

kafka-console-consumer.bat  --bootstrap-server localhost:9092 --topic 主题名 --from-beginning

测试情况就可通过发送者发送消息,消费者进行消费就ok了。关于简单的如何创建和消费有很多的示例,自行了解一下就好。

猜你喜欢

转载自blog.csdn.net/crossroads10/article/details/94588576