配置java環(huán)境
因?yàn)閗afka 是基于java 環(huán)境的,所以要先配置java
進(jìn)入到home路徑下,創(chuàng)建app文件夾,把jdk解壓到這個(gè)目錄
創(chuàng)建java的環(huán)境變量 ,linux 創(chuàng)建環(huán)境變量就是 編輯 /etc/profile 文件,然后source /etc/profile 使它生效
JAVA_HOME=/home/xxx/app/jdk1.8.0_151
JRE_HOME=/home/xxx/app/jdk1.8.0_151/jre
CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib
PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin
export JAVA_HOME JRE_HOME CLASS_PATH PATH
- 驗(yàn)證java環(huán)境是否配置完成,bash中輸入java 有反應(yīng)就可以了。
配置kafka
要啟動(dòng)kafka必須先啟動(dòng)zookeeper,zookeeper 是kafka 的分布式協(xié)調(diào)工具,來(lái)保證kafka 多節(jié)點(diǎn)運(yùn)行穩(wěn)定的?,F(xiàn)在kafka 安裝包里自帶了zookeeper 執(zhí)行文件。
- 先下載kafka 執(zhí)行文件 https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/
- 把kafka 解壓到app文件夾里
- cd到kafka目錄里面 運(yùn)行
./bin/zookeeper-server-start.sh config/zookeeper.properties啟動(dòng)zookeeper - 再開一個(gè)窗口運(yùn)行
./bin/kafka-server-start.sh config/server.properties啟動(dòng)kafka
小結(jié)
kafka 全是用的默認(rèn)配置文件。只需要載相關(guān)語(yǔ)言的sdk 然后 連接 localhost:9092 就好了