kafka叢集一鍵啟動與停止shell指令碼

準備工作：
已經配置了主機與ip對映關係，已經配置了免密登入；

一、啟動Kafka叢集的指令碼

自定義start_kafka_byfang.sh，啟動kafka叢集中所有節點

#!/bin/bash

BROKERS="hx2 hx3 hx4 hx5 hx6"  
APPHOME="/hadoop/kafka_2.11-1.1.0"
APP_NAME="kafka_2.11-1.1.0"

for i in $BROKERS
do
    echo "Starting ${APP_NAME} on ${i} "
    ssh
 
 ${i} "source /etc/profile;  ${APPHOME}/bin/kafka-server-start.sh -daemon ${APPHOME}/config/server.properties ;exit"
    if [[ $? -ne 0 ]]; then
        echo "Starting ${APP_NAME} on ${i} is  ok"
    fi
done
echo All $APP_NAME are started
exit 0

執行該shell之後，如下表示成功！

二、kafka叢集停止shell

#!/bin/bash

#BROKERS指你的主機名稱，
 

BROKERS="hx2 hx3 hx4 hx5 hx6"  
APPHOME="/hadoop/kafka_2.11-1.1.0"
APP_NAME="kafka_2.11-1.1.0"

for i in $BROKERS
do
    echo "Stopping ${APP_NAME} on ${i} "
    ssh ${i} "source /etc/profile;bash ${APPHOME}/bin/kafka-server-stop.sh;exit"
    if [[ $? -ne 0 ]]; then
        echo "Stopping ${APP_NAME} on ${i}
 
 is down"
    fi
done

echo All $APP_NAME are stopped
exit 0

執行成功的結果！！如下：