【环境搭建】Kafka安装（Windows 2022.9）

安装Zookeeper

官网下载安装包

本地解压

进入，新建文件夹“data”、“logs”

D:Developapache-zookeeper-3.7.1-bin

进入

D:Developapache-zookeeper-3.7.1-binconf

复制文件“zoo_sample.cfg”并重命名为“zoo.cfg”

修改文件“zoo.cfg”

dataDir=D:Developapache-zookeeper-3.7.1-bindata
    dataLogDir=D:Developapache-zookeeper-3.7.1-binlogs

添加系统环境变量，path下添加

D:Developapache-zookeeper-3.7.1-binin

打开cmd，输入命令，运行zookeeper服务端【不要关闭它，保持窗口和运行】

zkServe

安装kafka

官网下载安装包

本地解压

进入，新建文件夹“logs”

进入

D:Developkafka_2.12-3.2.1config

修改文件“server.properties”

log.dirs=D:\Develop\kafka_2.12-3.2.1\logs

修改文件“zookeeper.properties”

dataDir=D:\Develop\kafka_2.12-3.2.1\data

进入

D:Developkafka_2.12-3.2.1

cmd输入命令，启动kafka【不要关闭它，保持窗口和运行】

start binwindowskafka-server-start.bat configserver.properties

操作

创建topic

进入

D:Developkafka_2.12-3.2.1

cmd输入命令，创建一个topic

binwindowskafka-topics.bat --create  --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic kafka-test

cmd输入命令，查看已创建的topic

binwindowskafka-topics.bat --list --bootstrap-server localhost:9092

新建一个cmd，cmd输入命令，新建生产者Producer

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

新建一个cmd，cmd输入命令，新建消费者Consumer

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

Producer的cmd中输入文本消息，Consumer的cmd后稍后能看到。

常见问题

Kafka 创建topic 超时异常： Timed out waiting for a node assignment

可能连错了端口

zookeeper is not a recognized option

新版本的kafka，已经不需要依赖zookeeper进行新建topic等操作，不应当使用 binwindowskafka-topics.bat --create --zookeeper localhost:9092 --replication-factor 1 --partitions 1 --topic kafka-test 而是应该使用 binwindowskafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic kafka-test

参考资料

https://www.jianshu.com/p/9f4c0a90805b

https://cloud.tencent.com/developer/article/1892086