下載
官網(wǎng) https://kafka.apache.org/downloads
批注 2020-03-27 161812.png
Scala版本隨便選一個就行了疟暖，沒影響
使用kafka需要jdk環(huán)境蹦狂，確保win10已經(jīng)安裝了jdk
解壓
tgz文件解壓出tar文件再解壓就是kafka文件夾了誓篱，文件夾隨便放個地方就可以了凯楔，注意不要放到C:\Program Files里，路徑里有空格啟動時會報錯摆屯，自己創(chuàng)建的目錄名稱里也千萬不要加空格邻遏。
文件夾里就是這些文件，data和kafka-logs不是原有的虐骑，自己創(chuàng)建的存放data數(shù)據(jù)和log記錄的文件夾。
bin\windows目錄下存放的是windows可以用的命令廷没，包括啟動和關閉kafka糊饱、zookeeper
config目錄下存放的是配置文件
批注 2020-03-27 163633.png
修改配置
- 修改zookeeper.properties颠黎，把
dataDir改為自己創(chuàng)建的目錄
dataDir=C:\\tool\\kafka\\data
- 修改server.properties滞项，把
log.dirs改為自己創(chuàng)建的目錄
log.dirs=C:\\tool\\kafka\\kafka-logs
啟動
先啟動zookeeper再啟動kafka，關閉時先關閉kafka夭坪，不然有可能下次啟動kafka時報錯
下面的操作都是再kafka目錄下進行的
- 啟動zookeeper文判，啟動會不要關閉
PS C:\Users\ysh> cd c:\tool\kafka
PS C:\tool\kafka> .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
- 啟動kafka室梅，新開個窗口啟動kafka
PS C:\Users\ysh> cd c:\tool\kafka
PS C:\tool\kafka> .\bin\windows\kafka-server-start.bat .\config\server.properties
- 創(chuàng)建topic
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
- 生產(chǎn)、消費亡鼠，需要新開兩個窗口
// 啟動生產(chǎn)者
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
// 啟動消費者
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
在生產(chǎn)者窗口輸入的消息赏殃，在消費者窗口能夠顯示：
批注 2020-03-27 164756.png
批注 2020-03-27 164813.png
