有3臺(tái)服務(wù)器，ip分別為192.168.174.10，192.168.174.11，192.168.174.12。
1、官網(wǎng)下載，分別在每臺(tái)機(jī)器上解壓安裝
# 創(chuàng)建kafka的安裝目錄
mkdir -p /usr/local/software/kafka
# 解壓
tar -xvf kafka_2.12-1.1.0.tgz -C /usr/local/software/kafka/
2、修改每臺(tái)服務(wù)器的/etc/profile文件，設(shè)置kafka環(huán)境變量，添加如下內(nèi)容
export KAFKA_HOME=/usr/local/software/kafka/kafka_2.12-1.1.0
export PATH=$PATH:$KAFKA_HOME/bin
添加完后重啟配置，命令如下：
3、修改每臺(tái)服務(wù)器的$KAFKA_HOME/config下的server.properties文件，修改代理id和日志存放目錄
#指定代理id，borker.id可以任意指定，前提是保證集群內(nèi)每臺(tái)機(jī)器的broker.id唯一，第二臺(tái)機(jī)器設(shè)置為2...以此類推
broker.id=1
#設(shè)置日志目錄
log.dirs=/opt/data/kafka/kafka-logs
#設(shè)置zookeeper集群地址
zookeeper.connect=192.168.174.7:2181,192.168.174.8:2181,192.168.174.9:2181
#設(shè)置本機(jī)地址，設(shè)置為本服務(wù)器的ip地址。如果不設(shè)置會(huì)在創(chuàng)建主題和發(fā)送消息時(shí)，發(fā)生NOT LEADER FOR PARTITION異常。
host.name=192.168.174.10
4、配置完成后，分別啟動(dòng)3臺(tái)服務(wù)器的kafka，啟動(dòng)kafka前確保zookeeper集群已經(jīng)成功啟動(dòng)。
kafka-server-start.sh -daemon server.properties
5、驗(yàn)證是否成功啟動(dòng)
jps
如果看到kafka進(jìn)程，說明啟動(dòng)成功。
另外也可通過zookeeper客戶端查看zookeeper目錄結(jié)構(gòu)，如下：
#登錄zookeeper
zkCli . sh -server 192.168.174.7:2181
#查看目錄結(jié)構(gòu)
ls /
#查看已啟動(dòng)的kafka代理
ls /brokers/ids
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
