一、安裝
kafka中文文檔
1、kafka 需要java環境；下載下傳位址
①下載下傳java的jdk包後，安裝生成兩個目錄(自己指令)如圖
②變量環境配置
path下面添加:E:\tools\java_jdk\bin;E:\tools\java_jdk\jre\bin
系統變量添加
變量名:JAVA_HONME
變量值:E:\tools\java_jdk
2、kafka 最新版本内置了 zookeeper，是以不需要安裝zookeeper；
3、下載下傳kafka最新版本，下載下傳位址，因為下載下傳的是tgz檔案，是以不需要安裝，解壓到相應的地方就可以了。
4、bin 目錄下放的是啟動kafka的檔案，conf目錄下放的是kafka的各種配置檔案。
二、運作
簡單demo測試，不需要修改任何配置檔案，隻需要知道 zookeeper的預設端口是2181，生産者的預設端口是9092。
1、啟動zookeeper
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
2、啟動kafka
bin\windows\kafka-server-start.bat config\server.properties
3、建立主題topic，topic = demo
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
– 檢視建立的topic
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
4、啟動生産者 producer
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
啟動生産者之後進入編輯頁面，發送了 “nihao”，
5、啟動消費者 customer
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
當消費者啟動之後，收到了之前生産者發送的 “nihao”。