快速入門Kafka叢集的部署
阿新 • • 發佈:2018-12-16
一、解壓安裝包
(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 注:分別在每臺機器上執行如上命令