前言:最近在做Spark, 做到安装kafka, 安装完想配置一键启动和关闭, 编写启动的脚本执行没问题, 关闭的时候遇到了一些问题
,上网查资料也只能解决一半, 有些博客写的关闭脚本拿过来用执行不能成功,让同事看好久测试好久也没找出来,最后自己重写一遍就可以了。下面跟大家分享一下经验吧~
* 1.kafka 的config目录下 kafka-server-stop.sh <http://kafka-server-stop.sh>
有些问题,需要先修改一下官方提供的stop脚本,集群中的每一台机器都要改(注意 kafka 里面的k是小写) PIDS=$(ps ax | grep -i
'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}') 改为 PIDS=$(ps ax |
grep -i 'kafka' | grep java | grep -v grep | awk '{print $1}')
* 2.准备:
集群部署规划:
* 配置了主机名、映射
* 每台虚拟机之间可以免密登录
* 主机时间同步
* 关闭防火墙
* 配置环境变量
* 安装了zookeeper集群
<>kafka集群设置shell脚本一键启动
<>采用shell脚本启动kafka
* 首先新建文件 start-kafka.sh <http://start-kafka.sh> touch start-kafka.sh
* 进入文件: vi start-kafka.sh
* 编写脚本: #!/bin/sh for host in node1 node2 node3 do ssh $host "source
/etc/profile;nohup kafka-server-start.sh
/export/servers/kafka/config/server.properties >/dev/null 2>&1 &" echo "$host
kafka is running" done
* 写好后保存,加上执行权限: chmod u+x start-kafka.sh
* 运行: sh start-kafka.sh
* 查询kafka进程:
<>kafka集群设置shell脚本一键关闭
<>采用shell脚本启动kafka
* 首先新建文件 stop-kafka.sh <http://stop-kafka.sh> stop-kafka.sh
* 进入文件: vi stop-kafka.sh
* 编写脚本: #! /bin/sh for host in node-1 node-2 node-3 do ssh $host "source
/etc/profile; /export/servers/kafka/bin/kafka-server-stop.sh" echo "$host kafka
is stopping" done
* 写好后保存,加上执行权限: chmod u+x stop-kafka.sh
* 运行: sh stop-kafka.sh
* 查询kafka状态:
热门工具 换一换