zookeeper is not a recognized option Option异常
如图上所示,原因就是kafka0.9之后不再支持zookeeper的打开方式:
这个是0.9之后的打开方式
/usr/java/kafka_2.12-2.2.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
这个是0.9之前的打开方式
/usr/java/kafka_2.12-2.2.0/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning