window 上测试 kafka

刺骨的言语ヽ痛彻心扉 2022-07-13 14:17 175阅读 0赞

**一、下载 [kafka\_2.10-0.10.1.1.tgz][kafka_2.10-0.10.1.1.tgz]；注意下载二进制版本**

![Center][]

二、启动zookeeper（窗口1）；命令：bin\\windows\\zookeeper-server-start.bat   config\\zookeeper.properties

![Center 1][]

三、启动zookeeper（窗口2）；测试命令：zookeeper-shell.bat localhost:2181

![Center 2][]

四、启动kafka（窗口3）；命令：bin\\windows\\kafka-server-start.bat config\\server.properties

![Center 3][]

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

![Center 4][]

六、查看topic（窗口4）；命令：kafka-topics.bat --describe --zookeeper localhost:2181 --topic mytopic

![Center 5][]

七、发布/生产消息窗口（窗口5）；命令：kafka-console-producer.bat --broker-list localhost:9092 --topic mytopic

![Center 6][]

八、消费消息窗口（窗口5）；命令：kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic mytopic

![Center 7][]

九、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的环境变量路径，使其路径中不存在空格。

[kafka_2.10-0.10.1.1.tgz]: http://kafka.apache.org/downloads
[Center]: /images/20220713/19a43dde053b400fa5da23afeec7f9e0.png
[Center 1]: /images/20220713/57002f4427294095b376ab63c0787b0c.png
[Center 2]: /images/20220713/d3052ce8c41a43d1acf9359a39f352f6.png
[Center 3]: /images/20220713/35230a5200234672ad3e180348e70b7c.png
[Center 4]: /images/20220713/a1954fbc26ee4b3ca3844b3cd327ec3d.png
[Center 5]: /images/20220713/348ed1256e06468381b24b0650ee0137.png
[Center 6]: /images/20220713/e982b3967ec64d3fb331390cd7c8bb6a.png
[Center 7]: /images/20220713/dc06e2a11ced43e5a8702a99ca2a0ccb.png