1. 程式人生 > >快速入門Kafka叢集的部署

快速入門Kafka叢集的部署

一、解壓安裝包

(a)進入到此目錄下:
    cd /home/hadoop/tools/
(b)解壓kafka的壓縮包:
    tar kafka_2.11-0.11.0.2.tgz -C /home/hadoop/install/

二、如果覺得名字太長,可以修改名字

mv kafka_2.11-0.11.0.2/ kafka

三、修改配置檔案

(a)進入到此目錄下:
    cd /home/hadoop/install/kafka/config/
(b)修改"server.properties"檔案:
    vi server.properties

四、修改內容如下

#broker的全域性唯一編號,不能重複
broker.id=0

#是否允許刪除topic
delete.topic.enable=true

#kafka執行日誌存放的路徑
log.dirs=/home/hadoop/install/kafka/data/kafka-logs

#配置連線Zookeeper叢集地址
zookeeper.connect=hadoop102:2181,hadoop103:2181,hadoop104:2181

五、可以配置環境變數

(a)因本人用普通使用者,需要新增sudo:
    sudo vi /etc/profile
(b)修改內容如下:
    export KAFKA_HOME=/home/hadoop/install/kafka
    export PATH=$PATH:$KAFKA_HOME/bin
(c)使"/etc/profile"檔案生效:
    source /etc/profile

六、一臺機器配置完成,分發安裝包

xsync /etc/profile
xsync /home/hadoop/install/kafka

七、分別在02,03機器上修改配置檔案"server.properties"

注:在此目錄下:
/home/hadoop/install/kafka/config/server.properties

改為:
broker.id=1
broker.id=2
注:broker.id不得重複

八、啟動叢集

(a)進入到此目錄下:
    cd /home/hadoop/install/kafka/
(b)執行此命令
    bin/kafka-server-start.sh config/server.properties &
注:分別在每臺機器上執行如上命令

九、關閉叢集

(a)進入到此目錄下:
    cd /home/hadoop/install/kafka/
(b)執行此命令
    bin/kafka-server-stop.sh stop
注:分別在每臺機器上執行如上命令