windows 10 安裝 kafka
1.從官網下載下傳對應版本的kafka安裝包
- 前提:需要安裝jdk
- 下載下傳位址:https://mirrors.bfsu.edu.cn/apache/kafka/2.8.0/kafka_2.12-2.8.0.tgz
2. 解壓壓縮包
- 得到解壓後的檔案夾:kafka_2.12-2.7.0
3.啟動zookeeper
- 進入解壓的檔案夾目錄:./kafka_2.12-2.7.0/bin/windows
- 在目前目錄打開cmd
- 執行指令:zookeeper-server-start.bat …/…/config/zookeeper.properties
4.啟動kafka
- 進入解壓的檔案夾目錄:./kafka_2.12-2.7.0/bin/windows
- 在目前目錄打開cmd
- 執行指令:kafka-server-start.bat …/…/config/server.properties
5.建立kafka生産者和消費者
- 進入解壓的檔案夾目錄:./kafka_2.12-2.7.0/bin/windows
- 在目前目錄打開新的三個個cmd終端,分别用于建立topic,生産者和消費者
- 建立topic:kafka-topics.bat --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic testtopic
- 建立生産者指令:kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic testtopic
- 建立消費者指令:kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --from-beginning --topic testtopic
6.測試
- 在生産者的cmd終端中随便輸入消息,如:hello world,在消費者端觀察是否能接收到,如果能接收到則成功,如下截圖:
生産者:
消費者:
- 如果生産者發送消息時出現下面報錯:
Error while fetching metadata with correlation id : {LEADER_NOT_AVAILABLE}
将 config/server.properties 中的配置項:listeners=PLAINTEXT://:9092 放開即可,如下