集群启动脚本

jps集群启动脚本：jpsall.sh

#!/bin/bash for ip in flink01 flink02 flink03 do echo "------------------------------[ jps $ip ]-------------------------" ssh root@$ip "source /etc/profile;jps" done

zookeeper集群启动脚本：zk.sh

#!/bin/bash case $1 in "start"){ for i in flink01 flink02 flink03 do echo "------------zookeeper集群启动中...----------------" ssh $i "source /etc/profile;/opt/soft/zookeeper-3.4.6/bin/zkServer.sh start" done };; "stop"){ for i in flink01 flink02 flink03 do echo "------------正在停止zookeeper集群...---------------" ssh $i "source /etc/profile;/opt/soft/zookeeper-3.4.6/bin/zkServer.sh stop" done };; "status"){ for i in flink01 flink02 flink03 do echo "------------zookeeper集群状态...---------------" ssh $i "source /etc/profile;/opt/soft/zookeeper-3.4.6/bin/zkServer.sh status" done };; esac

kafka集群启动脚本：kf.sh

#!/bin/bash case $1 in "start"){ for i in flink01 flink02 flink03 do echo "------------kafka集群启动中...----------------" ssh $i "source /etc/profile;/opt/soft/kafka_2.11-0.11.0.0/bin/kafka-server-start.sh -daemon /opt/soft/kafka_2.11-0.11.0.0/config/server.properties &" done };; "stop"){ for i in flink01 flink02 flink03 do echo "------------正在关闭kafka集群...----------------" ssh $i "source /etc/profile;/opt/soft/kafka_2.11-0.11.0.0/bin/kafka-server-stop.sh" done };; esac