– zookeeper is not a recognized option主要原因是 Kafka 版本过高,命令不存在。

使用新版本:

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

 

 

相关文章: