window 下kafka 配置測試

1.準備工做

   1.1 java環境

   

  1.2 下載並解壓到D:\zookeeper-3.4.13  下載並解壓到 D:\kafka_2.12-2.1.0

2.安裝zookeeper 、kafka 我安裝在d盤根目錄下

  2.1 D:\zookeeper-3.4.13\conf => zoo_sample.cfg重命名爲zoo.cfg  並修改zoo.cfg 節點

  dataDir=D:/data/logs/zookeeper

 

 2.2 D:\kafka_2.12-2.1.0\config=> 並修改log.dirs 節點

 log.dirs=D:/data/logs/kafka

 

備註：路徑要麼是"/"分割，要麼是轉義字符"\\"

 2.3配置環境變量

 ZOOKEEPER_HOME: D:\zookeeper-3.4.13

 Path後追加 ;%ZOOKEEPER_HOME%\bin;

3.啓動zookeeper 、kafka

  3.1啓動zookeeper

  

 3.2啓動Kafka

   命令：.\bin\windows\kafka-server-start.bat .\config\server.properties  cmd 切換到 D:\kafka_2.12-2.1.0下執行

 

4.測試kafka

 4.1 建立topic

 命令：kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

 

  備註：以上依次顯示建立topic 和查詢topic 

  4.2 開啓生產者 消費者

  生產者命令：kafka-console-producer.bat --broker-list localhost:9092 --topic test

  消費者命令：kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning