kafka簡介
kafka是一種高吞吐量的分布式釋出訂閱消息系統。
環境搭建
1.首先安裝JDK
下載下傳位址
https://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html
然後配置環境變量,java、javac進行檢查我就不多說啦!
2.安裝Zookeeper
下載下傳位址:
https://zookeeper.apache.org/releases.html
下載下傳完成後,解壓在目錄D:bigdata下
注意:關于Zookeeper和kafka的路徑中最好不要出現空格,例如C:Program Files,否則将會導緻運作腳本時會出現問題
一、下載下傳完成後進入zookeeper的相關設定所在的檔案目錄,
D:\bigdata\zookeeper-3.4.13\conf
二、将
zoo_sample.cfg
重命名為
zoo.cfg
三、編譯zoo.cfg檔案
找到
dataDir=/tmp/zookeeper
這一行代碼
然後将其修改為
dataDir=D:\bigdata\zookeeper-3.4.13\data
如果沒有data檔案夾請建立
注意:路徑要麼是"/"分割,要麼是轉義字元"\",這樣會生成正确的路徑(層級,子目錄)。
四、配置zookeeper的系統環境變量
①在系統變量中建立
ZOOKEEPER_HOME=D:\bigdata\zookeeper-3.4.13

②編輯系統變量中的path變量,增加
%ZOOKEEPER_HOME%\bin
zookeeper的預設端口為2181
運作Zookeeper
打開cmd視窗,輸入指令
zkserver
,運作結果如圖則為正确
注意:運作zookeeper後不要關閉此視窗服務
安裝kafka
http://kafka.apache.org/downloads
進入頁面後下載下傳Binary downloads類型
下載下傳後解壓在D:bigdata目錄下
一、進入kafka配置檔案所在目錄,
D:\bigdata\kafka_2.11-2.2.0\config
二、編輯檔案
server.properties
修改kafka日志檔案位置
log.dirs=D:/bigdata/kafka_2.11-2.2.0/kafka-logs
注意下面這行代碼
如果在同一台機器上啟動,而且是預設端口不做修改,如果有變得另做修改。
kafka的預設端口為9092
運作kafka
一、cmd進入kafka的安裝目錄,
D:\bigdata\kafka_2.11-2.2.0
二、在指令行中輸入
.\bin\windows\kafka-server-start.bat .\config\server.properties
出現下圖代碼則為正确