前提：已配置好SSH服务器免密登录

1.群起脚本：

#Kafka群起脚本

#!/bin/bash
#定义linux集群
brokers="hadoop102 hadoop103 hadoop104"
#定义kafka目录
KAFKA_HOME="/opt/module/kafka"

KAFKA_NAME="Kafka"

echo "==============    开始启动Kafka集群    ==============="

for broker in $brokers
do
  ssh ${broker} -C "source /etc/profile; sh ${KAFKA_HOME}/bin/kafka-server-start.sh -daemon ${KAFKA_HOME}/config/server.properties"
  if [[ $? -eq 0 ]]; then
      echo "INFO:=======  [${broker}] Start successfully   =========="
  fi
done
echo "==============     Kafka集群启动成功！    ================"

写完后，为脚本添加执行权限：

chmod 777 start-kafka.sh

2.停止脚本：

说明：此停止脚本使用官方的kafka-server-stop.sh来停止Kafka进程，但是在使用kafka-server-stop.sh该脚本时会有些问题，具体操作请详见《官方kafka-server-start.sh脚本不能停止Kafka进程的解决办法》

#!/bin/bash
#Kafka集群停止脚本

brokers="hadoop102 hadoop103 hadoop104"
KAFKA_HOME="/opt/module/kafka"
KAFKA_NAME="Kafka"

echo "INFO : ============   开始停止Kafka集群   ============..."

for broker in $brokers
do
  echo "INFO : Shut down ${KAFKA_NAME} on ${broker} ..."
  ssh ${broker} "source /etc/profile;bash ${KAFKA_HOME}/bin/kafka-server-stop.sh"
  if [[ $? -ne 0 ]]; then
      echo "INFO : Shut down ${KAFKA_NAME} on ${broker} is down"
  fi
done

echo "INFO : ============   Kafka集群停止完成!    ===========..."

写完后，为脚本添加执行权限：

chmod 777 stop-kafka.sh

我是小K，大数据刚入门，希望踩过的坑对正在入门的你有帮助。在路上，再出发=。=