@批量启动kafka脚本
#! /bin/bash
node='master slave1 slave2'
kfServerPath="/opt/kafka_2.11-2.4.1"
case $1 in
"start"){
for i in $node
do
echo " --------启动 $i Kafka-------"
# 用于KafkaManager监控
ssh $i "export JMX_PORT=9988 && $kfServerPath/bin/kafka-server-start.sh -daemon $kfServerPath/config/server.properties "
done
};;
"stop"){
for i in $node
do
echo " --------停止 $i Kafka-------"
ssh $i "$kfServerPath/bin/kafka-server-stop.sh stop"
done
};;
esac