準備工作：

1.安裝jdk環境

http://www.oracle.com/technetwork/java/javase/downloads/index.html 

2.下載kafka的程式安裝包，並解壓

http://kafka.apache.org/downloads 

3.用命令列測試kafka生產和消費

在 kafka 目錄，按住shift+滑鼠右鍵->在此處開啟命令視窗(W) 

第一個命令視窗->啟動zookeeper服務： 

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

第二個命令視窗->啟動kfaka服務： 

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

第三個命令視窗->啟動啟produce: 

• 建立一個主題：

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testtopic

• 使用如下命令檢視建立的主題列表：

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

• 啟動生產者：

bin\windows\kafka-console-producer.bat --broker-list {本機ip}:9092 --topic testtopic

第四個命令視窗->啟動consumer：

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic testtopic --from-beginning 
 

1、安裝jdk7.x以上版本

2、在官方網站下載flink-1.4.0-bin-scala_2.11.tgz，並解壓

3、進入解壓的flink-1.4.0-bin-scala_2.11資料夾，再進入bin目錄

4、執行start-cluser.bat