说明：本脚本基于SSH服务器免密登录，如集群未配置SSH，参照：《SSH安装配置》 。

一、启动脚本：start-kafka-cluster.sh

#!/bin/bash
BROKERS="server1 server2 server3"
KAFKA_HOME="/usr/local/services/kafka/kafka_2.11-2.3.0"
KAFKA_NAME="kafka_2.11-2.3.0"

for i in $BROKERS
do
  echo "Starting ${KAFKA_NAME} on ${i} "
  ssh ${i} "source /etc/profile; nohup sh ${KAFKA_HOME}/bin/kafka-server-start.sh ${KAFKA_HOME}/config/server.properties > /dev/null 2>&1 &"
  if [[ $? -ne 0 ]]; then
      echo "Starting ${KAFKA_NAME} on ${i} is  ok"
  fi
done
echo All $KAFKA_NAME are started
exit 0

为脚本添加执行权限：

chmod a+x start-kafka-cluster.sh

二、停止脚本：stop-kafka-cluster.sh

#!/bin/bash
BROKERS="server1 server2 server3"
KAFKA_HOME="/usr/local/services/kafka/kafka_2.11-2.3.0"
KAFKA_NAME="kafka_2.11-2.3.0"

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

echo All $KAFKA_NAME are stopped
exit 0

为脚本添加执行权限：

chmod a+x stop-kafka-cluster.sh

参考资料

参考书籍：Kafka入门与实践

【4】Kafka集群启动/关闭脚本

原文：https://www.cnblogs.com/DeepInThought/p/11143981.html