1.kafka下载的3.6.2版本的

2.原因 --broker-list 弃用,应该用 --bootstrap-server 

3.启动生产者,.\bin\windows\kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test

4.启动消费者,.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

5.注意,cmd中没有.\

Logo

大数据从业者之家,一起探索大数据的无限可能!

更多推荐