kafka運行需要有jdk+zookeeper環境才能夠使用,jdk的安裝和環境變量的配置就不介紹了,這里需要先安裝zookeeper.可以從官網上下載
https://www.apache.org/dyn/closer.cgi/zookeeper/
清華鏡像：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/
-
將下載下來的包解壓一下,然后在conf目錄下將zoo_sample.cfg改成zoo.cfg,如圖
-
之后打開zoo.cfg將里面的dataDir的路徑改一下,我這里修改成下面的
dataDir=E:\\Software\\data\\logs\\zookeeper
-
之后把zookeeper配到環境變量里面,它的配置和jdk的配置類似
-
運行zookeeper,在cmd里面輸入zkserver會出現下面的就便是安裝成功
-
安裝kafka
kafka:http://kafka.apache.org/downloads
清華鏡像：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/
-
將下載下來的安裝包解壓,並進入到conf目錄下面找到server.properties文件
-
找到並編輯
log.dirs=E:\\Software\\data\\logs\\kafka
zookeeper.connect=localhost:2181 -
之后進入到kafka的目錄下執行下面的命令,可以使用在文件夾的空白處按着shift加鼠標右鍵打開命令窗口
.\bin\windows\kafka-server-start.bat .\config\server.properties
!每次運行kafka的時候都要把這個和上面的zkserver開啟 -
之后可以測試一下創建一個主題
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
-
之后開啟生產者,進入到bin/windows目錄下使用命令窗口
.\kafka-console-producer.bat --broker-list localhost:9092 --topic test
-
開啟消費者,進入到bin/windows目錄下使用命令窗口
.\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
-
之后可以在生產者那個窗口隨意輸入一些信息,之后就能在消費者那邊看到輸入的信息