创建脚本

登录 hadoop1，执行下面命令：

cd /program/bin

vim kafka.sh

增加下面内容：

#!/bin/bash

if [ $# -lt 1 ]
then
    echo "No Args Input..."
    exit ;
fi

case $1 in
"start")

        for i in hadoop1 hadoop2 hadoop3
        do
            ssh $i "/program/kafka_2.12-2.4.1/bin/kafka-server-start.sh -daemon /program/kafka_2.12-2.4.1/config/server.properties"
        done
;;
"stop")
        for i in hadoop1 hadoop2 hadoop3
        do
            ssh $i "/program/kafka_2.12-2.4.1/bin/kafka-server-stop.sh"
        done
;;

esac

保存退出

增加权限

chmod 777 kafka.sh

测试

启动zookeeper

因为 kafka 依赖 zookeeper，所以需要事先启动 zookeeper

启动参见：zookeeper-3.4.x集群：启动、停止服务、查看服务状态、jps

如果zk配置启动脚本，参见：zookeeper-3.4.x集群：启动、停止脚本

启动

./kafka.sh start

查看是否启动

jps

看到下面进程：

7550 Kafka

说明启动成功

停止

./kafka.sh stop

需要等几秒才能停止成功

原文出处：/show_1IX24ISW5HDt.html