Windows环境下的KAFKA安装过程及小问题详解

安装顺序安装过程中自己遇到的一些问题如何判断JDK是否安装成功命令行处的\windows\xx.bat什么意思启动KAFKA时报错Classpath is empty. Please build the project first e.g. by running 'gradlew jarA后续topic，producer，consumer运行过程中的注意事项有关于命令行窗口的注意事项 常见命令启动zookeeper启动kafka新建topic test查看所有已经建立的topic删除已有的topic test真正的删除topic test连接到zookeeper客户端显示当前目录下节点 创建生产者创建消费者

主要的安装流程在所给的参考文章中别的作者已介绍的足够详细 本片文章主要记录笔者在安装过程中的自己的一些遇到的问题

安装顺序

首先： https://www.cnblogs.com/lnice/p/9668750.html JDK的安装过程可以参考此篇文章开头中的一部分 因为新的版本的KAFKA已经内部整合了ZOOKEEPER的功能，所以我们并不需要再去下载ZOOKEEPER，接下的安装过程参考以下的一篇文章

其次： https://www.cnblogs.com/yougewe/p/9721086.html KAFKA的下载过程的注意点：需要下载的是binary二进制文件（而不是src源文件） 按照教程里面的步骤即可（解压至当前文件夹，举例：\kafka）

最后： https://blog.csdn.net/luanpeng825485697/article/details/81036028 KAFKA在python环境下的如何调试 目前还在学习中，如何使用python完成KAFKA的搭建，完成后会继续来分享的…

安装过程中自己遇到的一些问题

如何判断JDK是否安装成功

win+R，输入cmd，在打开的命令行窗口中输入java -version 若版本查询成功则表明JDK安装成功

命令行处的\windows\xx.bat什么意思

解压后的KAFKA文件夹会有一个windows文件夹，里面是后缀名为.bat的文件 我的个人理解是.sh是在LINUX下的系统文件运行格式，而.bat是在windows系统下的文件运行格式，所以windows下的KAFKA命令都需要小小的改变一下 例如： Linux: bin/zookeeper-server-start.sh config/zookeeper.properties windows: bin/windows/zookeeper-server-start.bat config/zookeeper.properties

启动KAFKA时报错Classpath is empty. Please build the project first e.g. by running 'gradlew jarA

kafka版本下载错误，查看下载解压后的文件夹是否包含src等字样 应该下载版本binary二进制文件

后续topic，producer，consumer运行过程中的注意事项

后续过程中需要保持zookeeper和kafka的命令行窗口打开 zookeeper，kafka，producer，consumer都需要另外开启命令行窗口

有关于命令行窗口的注意事项

命令行窗口需要在KAFKA的解压文件夹下打开 例如：加压后的文件夹为\kafka 在当前文件夹界面下shift+鼠标右键，打开当前命令行窗口 一般情况下的教程中的命令行窗口都是指上文所提的界面处

常见命令

启动zookeeper

bin/windows/zookeeper-server-start.bat config/zookeeper.properties

启动kafka

bin/windows/kafka-server-start.bat config/server.properties

新建topic test

bin/windows/kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看所有已经建立的topic

bin/windows/kafka-topics.bat --list --zookeeper localhost:2181 或者 bin/windows/kafka-topics.bat --zookeeper localhost:2181 --list

删除已有的topic test

bin/windows/kafka-topics.bat --delete --zookeeper localhost:2181 --topic test 注意：如果server.properties没有配置delete.topic.enable-true，此时的删除并不是真正的删除，只是将topic标记为：marked for deletion zookeeper-shell.bat localhost:2181连接到zookeeper后删除 rmr /brokers/topics/test

真正的删除topic test

上一小节rmr命令为删除

连接到zookeeper客户端

bin\windows\zookeeper-shell.bat localhost:2181

显示当前目录下节点

ls /brokers/topics

创建生产者

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

创建消费者

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning kafka版本为0.9.0.1时 bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning