1 安裝JDK

1、下載文件：https://www.oracle.com/java/technologies/downloads/#jdk17-windows 下載對應(yīng)windows使用的jdk。

2、安裝JDK并設(shè)置環(huán)境變量，JAVA_HOME和path

3、打開cmd，輸入java -version，驗證java是否安裝成功；

2 安裝ZOOKERPER

Kafka的運行依賴于Zookeeper，所以在運行Kafka之前我們需要安裝并運行Zookeeper。1、下載地址：http://zookeeper.apache.org/releases.html

2、解壓，然后進入conf中，把zoo_sample.cfg重命名成zoo.cfg，修改zoo.cfg，把dataDir的值改成”./zookeeper-3.7.0/data”，另外添加audit.enable=true；

3、添加系統(tǒng)變量，ZOOKEEPER_HOME和path

4、運行Zookeeper打開cmd然后執(zhí)行zkserver，cmd窗口不要關(guān)閉。

3 安裝并運行KAFKA

1、下載文件：https://kafka.apache.org/downloads.html，win10最好安裝kafka2.8版本，3.0版本有點問題，無法運行。2、解壓文件，打開config目錄，修改server.properties文件中l(wèi)og.dirs為”./logs”;

3、打開cmd，進入D:\kafka_2.13-2.8.1，輸入并執(zhí)行： .\bin\windows\kafka-server-start.bat .\config\server.properties

4、創(chuàng)建topics打開cmd，進入D:\kafka_2.13-2.8.1\bin\windows，輸入kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

5、打開一個producer打開cmd，進入D:\kafka_2.13-2.8.1\bin\windows，輸入kafka-console-producer.bat --broker-list localhost:9092 --topic test

6、打開一個consumer打開cmd，進入D:\kafka_2.13-2.8.1\bin\windows，輸入kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning