kafka测试服务器发送消息和接收消息

1：先进kafka目录

cd /usr/local/kafka/bin

2:启动生产者

./kafka-console-producer.sh --broker-list 192.168.1.251:19092 --topic test 

3：新打开一个xshell窗口

4:启动一个消费者

./kafka-console-consumer.sh --bootstrap-server 192.168.1.251:19092 --topic test --from-beginning

* 注意 上述动作2,3（生产者和消费者） 的test 是可以变得都是你的topic，写入你对应的topic

5：jar包启动

java -jar qir-0.0.1-SNAPSHOT.jar > a.log &