KafKa集群脚本

#!/bin/bash

BROKERS="zhaohui01 zhaohui02 zhaohui03"
# Kafka的安装目录
KAFKA_HOME="/opt/kafka-2.4.1"

case $1 in
"start"){
for broker in $BROKERS
	do
        echo "----------- 正在启动 kafka on ${broker} ----------"
        ssh $broker  "source /etc/profile;nohup ${KAFKA_HOME}/bin/kafka-server-start.sh -daemon ${KAFKA_HOME}/config/server.properties >/dev/null
 2>&1 &"
        if [ $? != 0 ];
        then
              echo "Can not starting kafka server on host ${broker}";
              exit 1;	
        fi
done
 		echo ----------- kafka 集群启动完成 -----------
}
;;
"stop"){
for broker in $BROKERS
      do
            echo --------- 正在停止 kafka on ${broker} -----------
            ssh $broker "source /etc/profile;${KAFKA_HOME}/bin/kafka-server-stop.sh  ${KAFKA_HOME}/config/server.properties"
      done
             echo ----------- kafka 集群停止完成 -----------
}
;;
esac