windows下搭建Kafka運行環境

一、安裝JDK1.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 Fileszookeeper-3.5.2-alpha）
3.打開D:Program Fileszookeeper-3.5.2-alphaconf，複制zoo_sample.cfg重命名成zoo.cfg
4.編輯zoo.cfg，修改dataDir為dataDir=/zookeeper-3.5.2-alpha/data
5.添加環境變量
   ZOOKEEPER_HOME          D:Program Fileszookeeper-3.5.2-alpha    Path 在現有的值後面添加     ;%ZOOKEEPER_HOME%in;
6.打開cmd，運行Zookeeper-zkserver

三、安裝Kafka1.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.0config下server.properties文件，把log.dirs修改為log.dirs=D:kafka_2.12-0.11.0.0kafka-logs
4.進入kafka文件目錄D:kafka_2.12-0.11.0.0，執行以下命令，啟動kafka通訊的服務器broker

.inwindowskafka-server-start.bat .configserver.properties

5.進入
kafka文件目錄
D:kafka_2.12-0.11.0.0inwindows，創建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.0inwindows，創建Producer和Consumer
（1）Producer
進入目錄D:kafka_2.12-0.11.0.0inwindows輸入如下命令

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

（2）Consumer
進入目錄D:kafka_2.12-0.11.0.0inwindows輸入如下命令

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