windows下搭建Kafka運行環境


一、安裝JDK

1.JDK下載路徑   http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

2.按照網上參考步驟,依次配置JAVA_HOME、Classpath和Path,然后打開cmd,運行java -version成功,則JDK配置成功;

 

二、安裝Zookeeper

由於Kafka的運行依賴於Zookeeper,所以在運行Kafka之前需要安裝並運行Zookeeper

1.Zookeeper下載路徑   http://zookeeper.apache.org/releases.html#download

2.解壓到文件下(我的目錄是  D:\Program Files\zookeeper-3.5.2-alpha)

3.打開D:\Program Files\zookeeper-3.5.2-alpha\conf,復制zoo_sample.cfg重命名成zoo.cfg

4.編輯zoo.cfg,修改dataDir為【dataDir=/zookeeper-3.5.2-alpha/data】

5.添加環境變量

   ZOOKEEPER_HOME          D:\Program Files\zookeeper-3.5.2-alpha
   Path 在現有的值后面添加     ;%ZOOKEEPER_HOME%\bin;

6.打開cmd,運行Zookeeper---zkserver

 

三、安裝Kafka

1.Kafka下載路徑  http://kafka.apache.org/downloads

2.解壓文件(我的目錄是D:\kafka_2.12-0.11.0.0   【這里不要在Program Files等文件名之間有空格的目錄下,不然一會執行會不識別路徑】)

3.打開目錄D:\kafka_2.12-0.11.0.0\config下server.properties文件,把log.dirs修改為【log.dirs=D:\kafka_2.12-0.11.0.0\kafka-logs】

4.進入kafka文件目錄D:\kafka_2.12-0.11.0.0,執行以下命令,啟動kafka通訊的服務器broker

 

.\bin\windows\kafka-server-start.bat .\config\server.properties


5.進入kafka文件目錄D:\kafka_2.12-0.11.0.0\bin\windows,創建kafka的消息topics

 

 

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testDemo


6.分別打開兩個cmd窗口,進入目錄D:\kafka_2.12-0.11.0.0\bin\windows,創建Producer和Consumer

 

(1)Producer

進入目錄D:\kafka_2.12-0.11.0.0\bin\windows輸入如下命令

 

kafka-console-producer.bat --broker-list localhost:9092 --topic testDemo

 

(2)Consumer

進入目錄D:\kafka_2.12-0.11.0.0\bin\windows輸入如下命令

 

kafka-console-consumer.bat --zookeeper localhost:2181 --topic testDemo


然后就可以在Producer中發信息,在Consumer中收信息了

 

 

學習地址:

1、http://www.cnblogs.com/alvingofast/p/kafka_deployment_on_windows.html

2、http://www.aboutyun.com/thread-12882-1-1.html


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM