kafka and zookeeper

在Windows安裝運行Kafka

1、安裝JAVA JDK

1、下載安裝包

 

http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

 

注意：根據32/64位操做系統下載對應的安裝包

 

2、添加系統變量：JAVA_HOME=C:\Program Files (x86)\Java\jdk1.8.0_144

 

2、安裝ZooKeeper

1、 下載安裝包

 

http://zookeeper.apache.org/releases.html#download

 

2、 解壓並進入ZooKeeper目錄，筆者：D:\Kafka\zookeeper-3.4.9\conf

 

3、 將「zoo_sample.cfg」重命名爲「zoo.cfg」

 

4、 打開「zoo.cfg」找到並編輯dataDir=D:\\Kafka\zookeeper-3.4.9\\tmp

 

5、 添加系統變量：ZOOKEEPER_HOME=D:\Kafka\zookeeper-3.4.9

 

6、 編輯path系統變量，添加路徑：%ZOOKEEPER_HOME%\bin

 

7、 在zoo.cfg文件中修改默認的Zookeeper端口（默認端口2181）

 

8、 打開新的cmd，輸入「zkServer「，運行Zookeeper

 

九、 命令行提示以下：說明本地Zookeeper啓動成功

 

注意：不要關了這個窗口

 

3、安裝Kafka

一、 下載安裝包

http://kafka.apache.org/downloads

注意要下載二進制版本

 

二、 解壓並進入Kafka目錄，筆者：D:\Kafka\kafka_2.12-0.11.0.0

三、 進入config目錄找到文件server.properties並打開

四、 找到並編輯log.dirs=D:\Kafka\kafka_2.12-0.11.0.0\kafka-logs

五、 找到並編輯zookeeper.connect=localhost:2181

六、 Kafka會按照默認，在9092端口上運行，並鏈接zookeeper的默認端口：2181

七、 進入Kafka安裝目錄D:\Kafka\kafka_2.12-0.11.0.0，按下Shift+右鍵，選擇「打開命令窗口」選項，打開命令行，輸入：

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

 

 

注意：注意：不要關了這個窗口，啓用Kafka前請確保ZooKeeper實例已經準備好並開始運行

4、測試

一、 建立主題，進入Kafka安裝目錄D:\Kafka\kafka_2.12-0.11.0.0，按下Shift+右鍵，選擇「打開命令窗口」選項，打開命令行，輸入：

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

 

 

查看主題輸入：

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

 

二、 建立生產者，進入Kafka安裝目錄D:\Kafka\kafka_2.12-0.11.0.0，按下Shift+右鍵，選擇「打開命令窗口」選項，打開命令行，輸入：

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

 

 

三、 建立消費者，進入Kafka安裝目錄D:\Kafka\kafka_2.12-0.11.0.0，按下Shift+右鍵，選擇「打開命令窗口」選項，打開命令行，輸入：

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