更新時(shí)間:2021-10-06 來源:黑馬程序員 瀏覽量:
為了方便將來進(jìn)行一鍵啟動(dòng)、關(guān)閉Kafka,我們可以編寫一個(gè)shell腳本來操作。將來只要執(zhí)行一次該腳本就可以快速啟動(dòng)/關(guān)閉Kafka。
1. 在節(jié)點(diǎn)1中創(chuàng)建 /export/onekey 目錄
cd /export/onekey
2. 準(zhǔn)備slave配置文件,用于保存要啟動(dòng)哪幾個(gè)節(jié)點(diǎn)上的kafka
node1.itcast.cnnode2.itcast.cnnode3.itcast.cn
3. 編寫start-kafka.sh腳本
vim start-kafka.shcat /export/onekey/slave | while read linedo{ echo $line ssh $line "source /etc/profile;export JMX_PORT=9988;nohup ${KAFKA_HOME}/bin/kafka-server-start.sh ${KAFKA_HOME}/config/server.properties >/dev/nul* 2>&1 & "}&waitdone
4.編寫stop-kafka.sh腳本
vim stop-kafka.shcat /export/onekey/slave | while read linedo{ echo $line ssh $line "source /etc/profile;jps |grep Kafka |cut -d' ' -f1 |xargs kill -s 9"}&waitdone
5. 給start-kafka.sh、stop-kafka.sh配置執(zhí)行權(quán)限
chmod u+x start-kafka.shchmod u+x stop-kafka.sh
6. 執(zhí)行一鍵啟動(dòng)、一鍵關(guān)閉
./start-kafka.sh./stop-kafka.sh
猜你喜歡:
Shell如何實(shí)現(xiàn)定時(shí)采集數(shù)據(jù)到HDFS?
Kafka基準(zhǔn)測(cè)試的測(cè)試步驟有哪些?
Kafka是什么?kafka有什么優(yōu)點(diǎn)??
大數(shù)據(jù)流處理:Flume、Kafka和NiFi的區(qū)別【大數(shù)據(jù)培訓(xùn)】