kafka_2.12-2.4.x集群-编写集群启动脚本、停止脚本-马育民老师

# 创建脚本

```
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](https://www.malaoshi.top/show_1IX1u5svJa22.html "zookeeper-3.4.x集群：启动、停止服务、查看服务状态、jps")

如果zk配置启动脚本，参见：[zookeeper-3.4.x集群：启动、停止脚本](https://www.malaoshi.top/show_1IX1u5m8PgAl.html "zookeeper-3.4.x集群：启动、停止脚本")

### 启动

```
./kafka.sh start
```

### 查看是否启动

```
jps
```

看到下面进程：
```
7550 Kafka
```

说明启动成功

### 停止

```
./kafka.sh stop
```
需要等几秒才能停止成功

原文出处：http://malaoshi.top/show_1IX24ISW5HDt.html