利用ssh来实现集群的启动和停止
vi kf.sh
#! /bin/bash
case $1 in
"start"){
for i in hadoop001 hadoop002 hadoop003
do
echo "-------启动 $i kafka----------"
ssh $i "source /etc/profile; /root/kafka/bin/kafka-server-start.sh -daemon /root/kafka/config/server.properties"
done
};;
"stop"){
for i in hadoop001 hadoop002 hadoop003
do
echo "------- 停止 $i kafka----------"
ssh $i "source /etc/profile; /root/kafka/bin/kafka-server-stop.sh stop "
done
};;
esac
:wq
chmod 777 kf.sh
./kf.sh start
./kf.sh stop