在作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
測試