kafka一键启动集群
我的kafka的3个节点是这样的。
启动kafka集群脚本
#!/bin/bash
echo "kafka cluster start"
ssh Desktop "source ~/.bashrc;$KAFKA/bin/kafka-server-start.sh -daemon $KAFKA/config/server.properties &"
ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA2/bin/kafka-server-start.sh -daemon $KAFKA2/config/server.properties &"
ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA3/bin/kafka-server-start.sh -daemon $KAFKA3/config/server.properties &"
关闭kafka集群脚本
#!/bin/bash
echo "kafka cluster stop"
ssh Desktop "source /home/appleyuchi/.bashrc;$KAFKA/bin/kafka-server-stop.sh &"
ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA2/bin/kafka-server-stop.sh &"
ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA3/bin/kafka-server-stop.sh &"
②中脚本运行后,并不会立刻关闭所有节点,
需要等待一段时间才能让所有kafka节点关闭。
注意点
①bash: : comman排查d not found
检查下脚本中有没有圆角字符的空格
②Desktop登录Laptop,
脚本是在Desktop中执行的,读取的是Desktop中的环境变量
因此虽然$KAFKA2是属于Laptop的节点,为了Desktop上脚本顺利执行,需要在Desktop的~/.bashrc中设置好$KAFKA2的具体值(这点非常重要,务必注意)。
否则会导致Reference中各种方案全部失效。
③$KAFKA/bin/kafka-run-class.sh中的开头加入
export JAVA_HOME="/home/appleyuchi/Java/jdk1.8.0_144"
并且
# Which java to use
if [ -z "$JAVA_HOME" ]; thenJAVA="java"
elseJAVA="$JAVA_HOME/bin/java"
fi
改成
# Which java to use
if [ -z "$JAVA_HOME" ]; thenJAVA="$JAVA_HOME/bin/java"
elseJAVA="$JAVA_HOME/bin/java"
fi
排查
如果无法顺利启动的话,
去$KAFKA/logs
下面查看具体的报错信息。
Reference:
[1]启动kafka集群,关闭kafka集群脚本(测试失败)
[2]shell脚本启动kafka集群(shell脚本启动kafka集群,先放着再说)
[3]Kafka集群启动停止脚本(测试失败)
[4]kafka 集群启动脚本 xkafka
[5]shell脚本,一次性启动kafka集群
[6]Kafka集群一键启动脚本
[7][资料] kafka集群设置shell脚本一键启动经验总结
[8]kafka集群启停脚本
[9]shell脚本启动kafka集群的多台节点
[10]【4】Kafka集群启动/关闭脚本
[11]一键启动和关闭zookeeper和kafka集群脚本
[12]集群自动化启动脚本(kafka,zookeeper,es)
[13]kafka集群启动脚本
[14]Kafka集群设置一键启动/一键停止脚本
[15]kafka集群开启及关闭脚本参考
[16]kafka集群一键启动shell脚本
[17]Kafka 集群启动关闭脚本
[18]kafka设置shell脚本文件一键启动和关闭
[19]zoookeeper集群和kafka集群启动快速启动脚本
[20]kafka深度研究之路(3)-kafka 与zk 集群启停脚本
[21]kafka批量启动、关闭脚本
[22]Linux Shell远程执行命令(测试失败)
kafka一键启动集群相关推荐
- Web基础配置篇(十四): Kafka单机、集群的安装配置及使用
Web基础配置篇(十四): Kafka单机.集群的安装配置及使用 一.概述 Apache Kafka是一个分布式发布 - 订阅消息系统和一个强大的队列,可以处理大量的数据,并使您能够将消息从一个端点传 ...
- Kafka:ZK+Kafka+Spark Streaming集群环境搭建(九)安装kafka_2.11-1.1.0
如何搭建配置centos虚拟机请参考<Kafka:ZK+Kafka+Spark Streaming集群环境搭建(一)VMW安装四台CentOS,并实现本机与它们能交互,虚拟机内部实现可以上网.& ...
- Kafka:ZK+Kafka+Spark Streaming集群环境搭建(二十一)NIFI1.7.1安装
一.nifi基本配置 1. 修改各节点主机名,修改/etc/hosts文件内容. 192.168.0.120master192.168.0.121slave1192.168.0.122 slave2 ...
- Kafka单机、集群模式安装详解(二)
本文环境如下: 操作系统:CentOS 6 32位 JDK版本:1.8.0_77 32位 Kafka版本:0.9.0.1(Scala 2.11) 接上篇 Kafka单机.集群模式安装详解(一) 6. ...
- kafka高可用集群搭建
################################################################# 物理环境(两台机子组成的真实集群): Desktop一个zk节点 L ...
- linux下kafka与zookeeper集群部署
*********************************配置主机名,通过主机名连接机器********************************* 比如说,已经有了三台主机 1,在li ...
- kafka专题:kafka单机和集群安装详情,Spring Boot如何整合Kafka
文章目录 1. kafka单机安装 1.1 server.properties核心配置 2. kafka集群安装 2.1 kafka集群可视化界面 3. springboot如何整合kafka 4. ...
- redis在Windows下以后台服务一键搭建集群(多机器)
redis在Windows下以后台服务一键搭建集群(多机器) 一.概述 此教程介绍如何在windows系统中多台机器之间布置redis集群,同时要以后台服务的模式运行.布置以脚本的形式,一键完成.多台 ...
- Kubernetes 搭建 Kafka 和 Zookeeper 集群(完整教程)
推荐阅读 Helm3(K8S 资源对象管理工具)视频教程:https://edu.csdn.net/course/detail/32506 Helm3(K8S 资源对象管理工具)博客专栏:https: ...
最新文章
- python基于tpot训练模型在获得最佳模型之后对模型进行交叉验证分析并可视化实战
- hdu5375(格雷码问题+简单DP)
- SQL2005-使用openrowset 里读取excel文件
- 如何从 Datagrid 中获得单元格的内容与 使用值转换器进行绑定数据的转换IValueConverter...
- 缴满15年能领多少钱 养老金计算公式网上疯传
- toad如何查看表字段备注(表字段的说明)
- 360手机浏览器_扰乱网络传播秩序!搜狗、360等手机浏览器国家网信办纳入首批重点整治范围...
- 运行SQL文件时报Lost connection to MySQL server during query
- X波段雷达对海探测试验与数据获取
- 山东大学暑期实训-饮食健康管理系统设计与实现(十三)
- 用户根据短信验证码注册
- maven module 路径_解决maven项目中-Dmaven.multiModuleProjectDirectory报错问题
- 返利网是如何做到订单跟踪的?
- 王者荣耀KPL秋季赛总决赛预测(AG VS DYG)
- INS-06101 IP adress of localhost could not be determined
- bzoj 3620: 似乎在梦中见过的样子
- CSP-SM常见问题及解答
- RNN LSTM GRU 代码实战 ---- 简单的文本生成任务
- 哪些东西不宜和羊肉一起吃啊/吃香蕉对胃有坏处吗
- 如何用word 2013 自动生成目录
热门文章
- windows下如何访问linux下的oracle数据库
- router-link-active 和 router-link-exact-active router-link-active
- C#异步编程のParallel(并行)
- table列宽控制,word-break等
- Java多线程-新特性-线程池
- sqlserver数据库大型应用解决方案总结 数据库负载均衡
- mysql反模式_MongoDB报表实例 -- 标签成员方案
- window.atob()与window.btoa()方法实现编码与解码
- 百度地图API : 修改marker图标(icon)
- Towxml 3.0来了,让小程序完美支持Markdown