kafka本地调试 基于Kafka的生产者消费者消息处理本地调试

主要本地调试命令

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

bin/kafka-server-stop.sh

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testSun

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testSun

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testSun

参考：

基于Kafka的生产者消费者消息处理本地调试

心得总结：
1. produce启动的时候參数使用的是kafka的port

consumer启动的时候使用的是zookeeper的port；
2.必须先创建topic才干使用。
3.topic本质是以文件的形式储存在zookeeper上的。