#!/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
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)