windows server 2019 安装kafka 3.2.0

windows server 2019 安装最新版 kafka 3.2.0

一、安装kafka之前，需安装JDK。

二、下载kafka 压缩文件并解压

kafka 3.2.0版本已内置zookeeper

下载地址：https://www.apache.org/dyn/closer.cgi?path=/kafka/3.2.0/kafka_2.12-3.2.0.tgz

该版本直接解压即可使用

切换到压缩文件目录下，再执行解压命令：tar -xzf kafka_2.12-3.2.0.tgz

三、配置data地址

kafka_2.12-3.2.0目录下，新建data文件夹，data文件夹内分别新建 kafka、zookeeper两个子文件夹

 

修改config目录下：

zookeeper.properties文件，

dataDir=（自己电脑目录）/kafka_2.12-3.2.0/data/zookeeper

server.properties文件
log.dirs=（自己电脑目录）/kafka_2.12-3.2.0/data/kafka

四、打开cmd命令窗口，切换到kafka_2.12-3.2.0目录下，先启动zookeeper

执行命令：bin\windows\zookeeper-server-start.bat config\zookeeper.properties

（bin/windows下是windows相关的启动文件）

启动成功：

 不要关闭该窗口！

五、另开cmd窗口，切换到kafka_2.12-3.2.0目录下，启动kaffka

执行命令：bin\windows\kafka-server-start.bat config\server.properties

启动成功：

不要关闭该窗口！

 六、另开cmd窗口，切换到kafka_2.12-3.2.0目录下，新建topic测试

执行命令：bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

创建test topic成功：

七、 查看已创建的topic

执行命令：bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

成功：

查看topic的描述信息：

执行命令：bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

成功：（之前创建的topic名为test ）

八、创建生产者producer

执行命令：bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic demo

输入消息：this is my first topic（请注意，在发送消息前，先建好消费者）

九、另开cmd窗口，切换到kafka_2.12-3.2.0目录下，创建消费者consumer消费消息

执行命令：bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning

 以上，windows server 2019整个kafka，从搭建，到成功发送消息，消费消息已完成。

从第五步开始，可直接切换到bin\windows\目录下，执行后面的命令，如：

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning

切换至bin\windows\，执行命令：kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning