在作kafka测试的时候,使用命令bin/kafka-console-consumer.sh --zookeeper 192.168.0.140:2181,192.168.0.141:2181 --topic test --from-beginning启动消费者,发现一只报错consumer zookeeper is not a recognized option,搜索了半天,一只没有解决,最后,换了一个低版本的kakfa,发如今启动的时候说使用 --zookeeper是一个过期的方法,此时,才知道原来在最新的版本中,这种启动方式已经被删除了,bootstrap
最后附上0.90版本以后启动消费者的 新方法: bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
测试