Kafka的使用（Windows中）-Toy模板网

这篇具有很好参考价值的文章主要介绍了Kafka的使用（Windows中）。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1、启动zookeeper

1.1、新建第一个cmd命令窗口

在Windows操作系统中找到解压后的kafka_2.12-3.5.1目录，可以将目录名称进行修改，我这边是修改为kafka

kafka命令windows,kafka,分布式

在这里输入cmd--->然后回车

kafka命令windows,kafka,分布式

会打开命令提示符（第一个窗口）

kafka命令windows,kafka,分布式

1.2、在（第一个窗口）中输入.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties然后回车

kafka命令windows,kafka,分布式

出现下图表示zookeeper启动成功

kafka命令windows,kafka,分布式

2、启动kafka

2.1新建第二个cmd命令窗口

在Windows操作系统中找到解压后的kafka_2.12-3.5.1目录（这里和上面一样）

kafka命令windows,kafka,分布式

在这里输入cmd-->然后回车

kafka命令windows,kafka,分布式

会打开命令提示符（第二个窗口）

2.2 在（第二个窗口）中输入.\bin\windows\kafka-server-start.bat .\config\server.properties然后回车（注:跟启动zookeeper的命令不一样）

kafka命令windows,kafka,分布式

出现下图表示Kafka启动成功

kafka命令windows,kafka,分布式

[注意：两个窗口都不能关闭]

3、测试kafka（创建主题）

3.1 新建第三个cmd命令窗口

在Windows操作系统中找到解压后的kafka_2.12-3.5.1目录（这里和上面一样）

kafka命令windows,kafka,分布式

在这里输入cmd-->然后回车

kafka命令windows,kafka,分布式

会打开命令提示符（第三个窗口）

方式一：在（第三个窗口）中输入.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test001然后回车

(若出现Created topic topic_test001表示成功)

kafka命令windows,kafka,分布式

如果出现下图所示的内容，使用第二种方式

kafka命令windows,kafka,分布式

出现以上问题的原因及解决方法：

这是因为安装的kafka版本过高，2.8+的kafka，已经不需要依赖zookeeper来创建topic，新版本使用 --bootstrap-server 参数，例：

#创建主题
.\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --create --topic topic_test001 --partitions 1

#查看主题
.\bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

方式二：在第三个窗口输入.\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --create --topic topic_test001 --partitions 1 然后回车 kafka命令windows,kafka,分布式