kafka集群设置shell脚本一键启动和关闭

前言：最近在做Spark， 做到安装kafka， 安装完想配置一键启动和关闭， 编写启动的脚本执行没问题， 关闭的时候遇到了一些问题 ，上网查资料也只能解决一半， 有些博客写的关闭脚本拿过来用执行不能成功，让同事看好久测试好久也没找出来，最后自己重写一遍就可以了。下面跟大家分享一下经验吧~

• 1.kafka 的config目录下 kafka-server-stop.sh 有些问题，需要先修改一下官方提供的stop脚本,集群中的每一台机器都要改（注意 kafka 里面的k是小写）

PIDS=$(ps ax | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}')
改为
PIDS=$(ps ax | grep -i 'kafka' | grep java | grep -v grep | awk '{print $1}')

• 2.准备：

集群部署规划：

配置了主机名、映射

每台虚拟机之间可以免密登录

主机时间同步

关闭防火墙

配置环境变量

安装了zookeeper集群

kafka集群设置shell脚本一键启动

采用shell脚本启动kafka

• 首先新建文件 start-kafka.sh

touch start-kafka.sh

进入文件：

vi start-kafka.sh

编写脚本:

#!/bin/sh
for host in node1 node2 node3
do
        ssh $host "source /etc/profile;nohup kafka-server-start.sh /export/servers/kafka/config/server.properties >/dev/null 2>&1 &" 
        echo "$host kafka is running"

done

写好后保存，加上执行权限：

chmod u+x start-kafka.sh

运行：

sh start-kafka.sh

查询kafka进程：

kafka集群设置shell脚本一键关闭

采用shell脚本启动kafka

• 首先新建文件 stop-kafka.sh

stop-kafka.sh

进入文件：

vi stop-kafka.sh

编写脚本:

#! /bin/sh
for host in node-1 node-2 node-3
do
        ssh $host "source /etc/profile; /export/servers/kafka/bin/kafka-server-stop.sh"
        echo "$host kafka is stopping"
done

写好后保存，加上执行权限：

chmod u+x stop-kafka.sh

运行：

sh stop-kafka.sh

查询kafka状态：