在Windows安装运行Kafka

本文来说下如何在Windows安装运行Kafka。因为kafka的运行需要依赖zookeeper，而zookeeper又要依赖jdk。

安装jdk安装zookeeper安装kafka

启动kafka自定义bat命令启动kafka创建topic创建kafka producer创建consumer测试 本文小结

安装jdk的过程就不说了

安装zookeeper的过程也不说了，出现下面的情况，说明zookeeper已经安装成功了

我安装的kafka是以下的版本，安装最新版本的时候，出现错误，无论怎么都不行。可能是jdk，zookeeper和kafka之间存在版本之间的冲突。下载链接：https://kafka.apache.org/downloads

解压以后如下图所示

在cmd中进入kafka根目录。

输入以下命令：

.binwindowskafka-server-start.bat .configserver.properties

出现kafka的版本号，说明kafka启动成功

前面这样启动kafka实在是有点不方便，下面我们自己编写一个bat命令来启动kafka。server.properties路径如下

kafka-server-start.bat路径如下

本质就是将上面的两个路径弄成一个bat命令来执行就行了

D:kafkakafka_2.11-2.3.1binwindowskafka-server-start.bat D:kafkakafka_2.11-2.3.1configserver.properties
pause

启动kafka

在cmd中进入kafkabinwindows目录，输入以下命令：

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

test和tests两个主题创建成功。

在cmd中进入kafkabinwindows目录，输入以下命令：

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

注意这里的端口和server.properties的端口号一致。

在cmd中进入kafkabinwindows目录，输入以下命令：

kafka-console-consumer.bat  --bootstrap-server localhost:9092 --topic test 

一个生产者，两个消费者

测试结果表明，这个是成功的。

本文详细介绍了kafka在windows环境下的安装以及在cmd中的使用，后续会继续介绍kafka在Java环境中的使用，即springboot如如何来整合springboot。