天天看点

window 上测试 kafka

一、下载 kafka_2.10-0.10.1.1.tgz;注意下载二进制版本

window 上测试 kafka

二、启动zookeeper(窗口1);命令:bin\windows\zookeeper-server-start.bat   config\zookeeper.properties

window 上测试 kafka

三、启动zookeeper(窗口2);测试命令:zookeeper-shell.bat localhost:2181

window 上测试 kafka

四、启动kafka(窗口3);命令:bin\windows\kafka-server-start.bat config\server.properties

window 上测试 kafka

五、创建topic(窗口4);命令:bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic mytopic

window 上测试 kafka

六、查看topic(窗口4);命令:kafka-topics.bat --describe --zookeeper localhost:2181 --topic mytopic

window 上测试 kafka

七、发布/生产消息窗口(窗口5);命令:kafka-console-producer.bat --broker-list localhost:9092 --topic mytopic

window 上测试 kafka

八、消费消息窗口(窗口5);命令:kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic mytopic

window 上测试 kafka

九、producer窗口输入,可以在consumer窗口输出

十、问题:在启动zookeeper时,出现:命令语法不正确, 找不到或无法加载主类   Files\Java\jdk1.8.0_51\lib; C:\Program: 的错误。

原因:因为是windows上文件夹存在空格导致启动zookeeper失败,即是JAVA_HOME的环境变量中存在空格(C:\Program Files\Java\jdk1.8.0_51)导致。

解决办法:修改Java的环境变量路径,使其路径中不存在空格。