Kafka集群启动关闭脚本
2018-09-27 本文已影响0人
baifuwa
集群是三台机器,Zookeeper 是利用Kafka中自带的,并未单独部署。
在/home下建一个kafka.list文件,用于存储群集列表,每台机器名单独一行。
启动脚本直接启动zookeeper,然后再启动kafka。
脚本内容如下:
#!/bin/sh
case "$1" in
start)
for host in `cat /home/kafka.list`
do
ssh $host "source /etc/profile;nohup /usr/share/kafka/bin/zookeeper-server-start.sh /usr/share/kafka/config/zookeeper.properties >/dev/null 2>1 &"
echo "$host zookeeper is running"
done
sleep 100
for host in `cat /home/kafka.list`
do
ssh $host "source /etc/profile;nohup /usr/share/kafka/bin/kafka-server-start.sh /usr/share/kafka/config/server.properties >/dev/null 2>&1 &"
echo "$host kafka is running"
done
;;
stop)
for host in `cat /home/kafka.list`
do
ssh $host "source /etc/profile;jps |grep Kafka |cut -b 1-5|xargs kill -9"
echo "$host kafka is stop"
ssh $host "source /etc/profile;nohup /usr/share/kafka/bin/zookeeper-server-stop.sh"
echo "$host zookeeper is stoping"
done
;;
*)
echo "Usage: cassandra {start|stop}"
exit 1
;;
esac