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

Logo

华为云1024程序员节送福利,参与活动赢单人4000元礼包,更有热门技术干货免费学习

更多推荐