首页 > 代码库 > 基于Kafka的生产者消费者消息处理本地调试
基于Kafka的生产者消费者消息处理本地调试
(尊重劳动成果,转载请注明出处:http://blog.csdn.net/qq_25827845/article/details/68174111冷血之心的博客)
Kafka下载地址:http://download.csdn.net/download/qq_25827845/9798176
安装解压即可
配置修改zookeeper.properties 与 server.properties修改为本地路径,如图所示:
将config文件夹中的zookeeper.properties 与 server.properties拷贝到bin/windows下。
windows的服务脚本在bin\windows
(1)启动服务:启动zookeeper:
zookeeper-server-start.bat zookeeper.properties
cd到bin\windows目录, 并把zookeeper.properties 拷贝到这里或者在命令中带上绝对路径
(2)启动kafka:
kafka-server-start.bat server.properties
(3)关闭服务:在启动服务的cmd窗口, 按ctrl+c另开窗口,
执行脚本kafka-server-stop.bat zookeeper-server-stop.bat
(4)消费测试:建立topic:
kafka-topics.bat --create --zookeeper localhost:2181--replication-factor 1 --partitions 1 --topic test_ywq
(5)建立一个Producer, 打开一个cmd窗口,执行:
kafka-console-producer.bat --broker-list localhost:9092 --topic test_ywq
(6)建立一个Consumer, 打开一个cmd窗口,执行:
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test_ywq
(7)生产和消费测试:
当在生产者的消息为hello?时,可以看到,在消费者里边可以消费到hello?
心得总结:
1. produce启动的时候参数使用的是kafka的端口
consumer启动的时候使用的是zookeeper的端口;
2.必须先创建topic才能使用;
3.topic本质是以文件的形式储存在zookeeper上的。
如果对你有帮助,记得点赞哦~欢迎大家关注我的博客,可以进群366533258一起交流学习哦~
基于Kafka的生产者消费者消息处理本地调试