windows下部署kafka_2.12-1.1.0

安裝JDK

安裝zookeeper

下載下傳位址：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.4.12/zookeeper-3.4.12.tar.gz

解壓至一個目錄

進入conf目錄

複制zoo_sample.cfg，并重命名為zoo.cfg

編輯zoo.cfg檔案

修改dataDir路徑，如dataDir=H:\\proj\\zookeeper-3.4.12\\tmp

添加環境變量

ZOOKEEPER_HOME = H:\proj\zookeeper-3.4.12
           

編輯path系統變量，添加路徑

%ZOOKEEPER_HOME%\bin
           

啟動zookeeper

打開cmd，輸入zkServer，運作Zookeeper

安裝kafka

下載下傳位址：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/1.1.0/kafka_2.12-1.1.0.tgz

解壓至一個目錄

進入config目錄

編輯server.properties檔案 修改log.dirs路徑，如log.dirs=H:\\proj\\kafka_2.12-1.1.0\\kafka-logs

修改zookeeper.connect=localhost:2181

啟動kafka

進入kafka安裝目錄

建立一個startup.bat并編輯輸入

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

運作startup.bat

可能會遇到如下問題：

H:\proj\kafka_2.12-1.1.0>.\bin\windows\kafka-server-start.bat .\config\server.properties
Error: missing `server' JVM at `D:\Program Files (x86)\java\bin\server\jvm.dll'.
Please install or use the JRE or JDK that contains these missing components.
           

說明你隻安裝了jre，至官網下載下傳并安裝jdk即可

傳送門：http://download.oracle.com/otn-pub/java/jdk/8u171-b11/512cd62ec5174c3487ac17c61aaa89e8/jdk-8u171-windows-x64.exe?AuthParam=1528562405_fc3a2f704a0b57c2c6fd0db92345334b

成功啟動

測試

建立主題

進入kafka安裝目錄

按下Shift+右鍵，選擇“打開指令視窗”選項，打開指令行

輸入如下語句

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

建立生産者

輸入如下語句

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic hello
           

建立消費者

進入kafka安裝目錄

按下Shift+右鍵，選擇“打開指令視窗”選項，再打開一個指令行

輸入如下語句

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic hello