天天看點

windows 10 安裝 kafkawindows 10 安裝 kafka

windows 10 安裝 kafka

1.從官網下載下傳對應版本的kafka安裝包

  1. 前提:需要安裝jdk
  2. 下載下傳位址:https://mirrors.bfsu.edu.cn/apache/kafka/2.8.0/kafka_2.12-2.8.0.tgz

2. 解壓壓縮包

  1. 得到解壓後的檔案夾:kafka_2.12-2.7.0

3.啟動zookeeper

  1. 進入解壓的檔案夾目錄:./kafka_2.12-2.7.0/bin/windows
  2. 在目前目錄打開cmd
  3. 執行指令:zookeeper-server-start.bat …/…/config/zookeeper.properties

4.啟動kafka

  1. 進入解壓的檔案夾目錄:./kafka_2.12-2.7.0/bin/windows
  2. 在目前目錄打開cmd
  3. 執行指令:kafka-server-start.bat …/…/config/server.properties

5.建立kafka生産者和消費者

  1. 進入解壓的檔案夾目錄:./kafka_2.12-2.7.0/bin/windows
  2. 在目前目錄打開新的三個個cmd終端,分别用于建立topic,生産者和消費者
  3. 建立topic:kafka-topics.bat --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic testtopic
  1. 建立生産者指令:kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic testtopic
  1. 建立消費者指令:kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --from-beginning --topic testtopic

6.測試

  1. 在生産者的cmd終端中随便輸入消息,如:hello world,在消費者端觀察是否能接收到,如果能接收到則成功,如下截圖:
生産者:
windows 10 安裝 kafkawindows 10 安裝 kafka
消費者:
windows 10 安裝 kafkawindows 10 安裝 kafka
  1. 如果生産者發送消息時出現下面報錯:

Error while fetching metadata with correlation id : {LEADER_NOT_AVAILABLE}

将 config/server.properties 中的配置項:listeners=PLAINTEXT://:9092 放開即可,如下

windows 10 安裝 kafkawindows 10 安裝 kafka