创建消费者命令 ,并进行消费:
.\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了。关于简单的如何创建和消费有很多的示例,自行了解一下就好。