说明：本脚本基于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"echo "INFO : Begin to start kafka cluster ..."for broker in $brokers
doecho "INFO : Starting ${KAFKA_NAME} on ${broker} ..."ssh ${broker} -C "source /etc/profile; sh ${KAFKA_HOME}/bin/kafka-server-start.sh -daemon ${KAFKA_HOME}/config/server.properties"if [[ $? -eq 0 ]]; thenecho "INFO:[${broker}] Start successfully"fi
done
echo "INFO:Kafka cluster starts successfully !"

为脚本添加执行权限：

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"echo "INFO : Begin to stop kafka cluster ..."for broker in $brokers
doecho "INFO : Shut down ${KAFKA_NAME} on ${broker} ..."ssh ${broker} "source /etc/profile;bash ${KAFKA_HOME}/bin/kafka-server-stop.sh"if [[ $? -ne 0 ]]; thenecho "INFO : Shut down ${KAFKA_NAME} on ${broker} is down"fi
doneecho "INFO : kafka cluster shut down completed!"

为脚本添加执行权限：

chmod a+x stop-kafka-cluster.sh

参考资料

参考书籍：Kafka入门与实践

作者： DeepInThought
出处： https://www.cnblogs.com/DeepInThought
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。

转载于:https://www.cnblogs.com/DeepInThought/p/11143981.html

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

kafka 集群启动失败：FATAL [KafkaServer id=0] Fatal error during KafkaServer startup.
在测试 kafka 集群时,关闭 kafka 后,再次启动 kafka 集群时,遇到此问题,具体内容如下: FATAL [KafkaServer id=0] Fatal error during Ka ...
kafka-manager监控kafka集群启动失败
使用kafka-manager监控kafka出错: 启动hadoop集群,启动zookeeper集群,启动kafka集群后,在启动kafka-manager监控kafka集群时,发现kafka-man ...
kafka集群下载、启动、部署、测试
文章目录一.kafka基础操作 1. kafka下载 2. 解压 3. 重命名 4. 在kafka目录下创建 data 数据文件夹 5. 修改配置文件 6. 配置kafka环境变量 7. 刷新环境变 ...
【kafka专栏】使用shell脚本快速安装kafka集群(含视频)
我们本节来正式安装kafka集群,安装kafka集群主要的方式有两种:一种是纯手动安装,一种是使用自动化shell脚本安装.纯手动安装的方式需要一台服务器.一台服务器的去操作,在服务器较多的情况下工作 ...
kafka集群操作指南
kafka集群操作指南 @(KAFKA)[kafka, 大数据] kafka集群操作指南一单机版安装二集群安装三集群启停操作四topic相关的操作五某个broker挂掉本机器可重启六某个b ...
Kafka（二）- Kafka集群部署
文章目录一.安装部署 1. 集群规划 2. 虚拟机前置准备工作 (1)配置IP (2)修改主机名称和hosts文件 (3)关闭防火墙,关闭防火墙开机自启 (4)克隆虚拟机 3. 集群部署 (1)解压 ...
融云发送自定义消息_数据源管理 | Kafka集群环境搭建，消息存储机制详解
一.Kafka集群环境 1.环境版本版本:kafka2.11,zookeeper3.4 注意:这里zookeeper3.4也是基于集群模式部署. 2.解压重命名 tar -zxvf kafka_2. ...
数据源管理 | Kafka集群环境搭建，消息存储机制详解
本文源码:GitHub·点这里 || GitEE·点这里一.Kafka集群环境 1.环境版本版本:kafka2.11,zookeeper3.4 注意:这里zookeeper3.4也是基于集群模式部 ...
几种常见的Kafka集群监控工具「送书」
本文选自电子工业出版社的新书<kafka进阶>,推荐一下. 送书规则:文末留言,精选精彩留言,对留言点赞最多的4位包邮送书一本~ 截止时间:2022.06.20 8:00 一个功能健全的 ...
Kafka 集群搭建（含 ZK 模式和 Kraft 模式）
前言环境介绍虚拟机软件:VirtualBox Linux 发行版本:Ubuntu 20.04.4 虚拟机核心数:1 core 虚拟机内存:2 GB JDK 版本:1.8.0_202 ZK 版本:3 ...

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

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

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

参考资料

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

最新文章

热门文章