1 安裝JDK
1.1 官網(wǎng)下載Java SE Runtime Environment:
? ? ? http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html
1.2 配置電腦環(huán)境變量:
? ? (1) 右鍵點(diǎn)擊“我的電腦” -> "屬性"->"高級系統(tǒng)設(shè)置" -> "環(huán)境變量"蟀给。
? ? (2)設(shè)置JAVA_HOME: C:\Program Files\Java\jre1.8.0_131(此為默認(rèn)安裝路徑蝙砌,以實際安裝路徑為準(zhǔn)),修改PATH: 在現(xiàn)有的值后面添加"; %JAVA_HOME%\bin"(注意分號)跋理。
?1.3 運(yùn)行cmd择克,執(zhí)行"java -version",查看當(dāng)前已安裝Java版本前普,驗證安裝是否成功肚邢。
2 Kafka的運(yùn)行依賴于Zookeeper,故需要安裝并運(yùn)行Zookeeper
2.1 下載安裝文件: http://www.apache.org/dyn/closer.cgi/zookeeper/
2.2 解壓文件(本文解壓到?C:\zookeeper-3.4.10)
2.3 打開C:\zookeeper-3.4.10\conf拭卿,備份zoo_sample.cfg骡湖,然后重命名為zoo.cfg
2.4 打開zoo.cfg
? ? ? 設(shè)置dataDir=/zookeeper/data
2.5 添加如下系統(tǒng)變量:
? ? ? ZOOKEEPER_HOME:?C:\zookeeper-3.4.10
? ? ? Path: 在現(xiàn)有的值后面添加 ";%ZOOKEEPER_HOME%\bin;"
2.6 運(yùn)行Zookeeper: 打開cmd然后執(zhí)行:
? ? ? zkserver
啟動Zookeeper也可以去接下來介紹的Kafka內(nèi)進(jìn)行zookeeper.properties文件的配置和zookeeper-server-start.bat文件的啟動。
3 安裝并運(yùn)行Kafka
3.1 下載安裝文件:http://kafka.apache.org/downloads.html
3.2 解壓文件(本文解壓到 C:\kafka_2.12-0.11.0.0)
3.3 打開C:\kafka_2.12-0.11.0.0\config
3.4 從文本編輯器里打開 server.properties
3.5 修改配置參數(shù):
? ? ? 第34行 listeners=PLAINTEXT://127.0.0.1:9092峻厚;
? ? ? 第63行 log.dirs=C:/kafka_2.12-0.11.0.0/kafka-logs响蕴;
? ? ? 第126行 zookeeper.connect=127.0.0.1:2181;
3.6 打開cmd
3.7 進(jìn)入kafka文件目錄: cd? C:\kafka_2.12-0.11.0.0
3.8 輸入并執(zhí)行以打開kafka:
.\bin\windows\kafka-server-start.bat ?.\config\server.properties
4 創(chuàng)建topics
4.1 通過Cmd進(jìn)入C:\kafka_2.12-0.11.0.0\bin\windows
4.2 創(chuàng)建topic
? ? ?kafka-topics.bat --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
? ? ?查看所有topic
? ? ?kafka-topics.bat --list --zookeeper 127.0.0.1:2181
5. 開啟Producer
? ? ?打開一個cmd窗口惠桃,執(zhí)行以下操作:
? ? ? cd? C:\kafka_2.12-0.11.0.0\bin\windows
? ? ? kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic test
6. 開啟Consumer浦夷,監(jiān)視Producer
? ? 打開一個cmd窗口辖试,執(zhí)行以下操作:
? ? ? cd? C:\kafka_2.12-0.11.0.0\bin\windows
? ? ? kafka-console-consumer.bat --zookeeper 127.0.0.1:2181 --topic test
當(dāng)在producer窗口輸入內(nèi)容時,可以在consumer窗口看到收到的內(nèi)容劈狐。