Kafka在window上安裝部署

1.准備工作  

①jdk

•  具體自行百度安裝jdk,配置好 JAVA_HOME和path,
• 下載地址:   http://www.oracle.com/technetwork/java/javase/downloads/index.html,
•  注意,  選擇1.8的版本,然后環境變量JAVA_HOME,不要選擇默認的"C:\Program Files\Java\jdk1.8.0_151" , 因為文件夾路徑不能有空格,后面可能啟動kafka服務出錯.

②zookeeper

• 下載安裝包：http://zookeeper.apache.org/releases.html#download
• 解壓目錄: D:\Tool,

  1.進入Zookeeper設置目錄，D:\Tool\zookeeper-3.4.13\conf
  2. 將“zoo_sample.cfg”重命名為“zoo.cfg”
  3. 在文本編輯器（如notepad）中打開zoo.cfg
  4. 找到並編輯dataDir=D:/Tool/zookeeper-3.4.13/tmp (可以自定義文件夾)
  5. 與Java中的做法類似，我們在系統環境變量中添加：
  　　a. 在系統變量中添加ZOOKEEPER_HOME =D:\Tool\zookeeper-3.4.13
  　　b. 編輯path系統變量，添加為路徑 %ZOOKEEPER_HOME%\bin;
  6. 在zoo.cfg文件中修改默認的Zookeeper端口（默認端口2181,可以不用修改）

• 測試 : 打開新的cmd，輸入zkServer，運行Zookeeper,成功如下所示,

 

③kafka

• 下載 http://kafka.apache.org/downloads.html,注意要下載二進制版本的,

              

解壓到目錄 D:\Tool\kafka_2.11-2.1.1

1. 編輯文件Kafka配置文件， D:\Tool\kafka_2.11-2.1.1\config\server.properties
2. 找到並編輯log.dirs=D:\Tool\kafka_2.11-2.1.1\kafka-log, (自定義文件夾)
3. 找到並編輯zookeeper.connect=localhost:2181。表示本地運行(默認的可以不改)
4. Kafka會按照默認，在9092端口上運行，並連接zookeeper的默認端口：2181。
 

二、運行和測試

注意：在啟動Kafka前，先運行Zookeeper實例。 (前面的cmd命令:zkserver)

①啟動Kafka服務器

　　新建cmd窗口:
      cd D:\Tool\kafka_2.11-2.1.1 

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

     

 

②創建主題

    新建cmd窗口:
    cd D:\Tool\kafka_2.11-2.1.1\bin\windows
    kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic haha

     

 

③創建生產者

    新建cmd窗口:
    cd D:\Tool\kafka_2.11-2.1.1\bin\windows
    kafka-console-producer.bat --broker-list localhost:9092 --topic haha

    

 

④創建消費者

    新建cmd窗口:
    cd D:\Tool\kafka_2.11-2.1.1\bin\windows
    kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic haha--from-beginning

    

 

⑤生產消息並消費