🔥码云GVP开源项目 12k star Uniapp+ElementUI 功能强大 支持多语言、二开方便! 广告
1. 在node1的/home/atguigu/bin目录下创建文件kf.sh脚本文件 ``` vim kf.sh ``` 脚本如下: ``` #! /bin/bash case $1 in "start"){ for i in node1 node2 node3 do echo " --------启动 $i Kafka-------" ssh $i "/opt/module/kafka/bin/kafka-server-start.sh -daemon /opt/module/kafka/config/server.properties" done };; "stop"){ for i in node1 node2 node3 do echo " --------停止 $i Kafka-------" ssh $i "/opt/module/kafka/bin/kafka-server-stop.sh " done };; esac ``` 2. 添加执行权限 ``` chmod +x kf.sh ``` 3. 启动集群命令 ``` /home/atguigu/bin/kf.sh start ``` 4. 停止集群命令 ``` /home/atguigu/bin/kf.sh stop ``` **注意:停止Kafka集群时,一定要等Kafka所有节点进程全部停止后再停止Zookeeper集群。因为Zookeeper集群当中记录着Kafka集群相关信息,Zookeeper集群一旦先停止,Kafka集群就没有办法再获取停止进程的信息,只能手动杀死Kafka进程了。**