1.连接相关xshell,打开两个窗口一个给生产者用一个给消费者用
在生产者里输入:./kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic消费者里输入:./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testTopic --from-beginning