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 &

6：重启kafka

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties &

bin/kafka-server-start.sh -daemon config/server.properties &

7：查看当前占用端口情况

netstat -tunlp