版权声明:阅后即焚!本文为博主原创文章,未经博主允许不得转载哦。喜欢就点赞评论+关注吧 !感谢阅读,希望能帮助到大家,谢谢大家的支持! https://blog.csdn.net/OYziqing/article/details/86499561
前言:最近在做Spark, 做到安装kafka, 安装完想配置一键启动和关闭, 编写启动的脚本执行没问题, 关闭的时候遇到了一些问题 ,上网查资料也只能解决一半, 有些博客写的关闭脚本拿过来用执行不能成功,让同事看好久测试好久也没找出来,最后自己重写一遍就可以了。下面跟大家分享一下经验吧~
- 1.kafka 的config目录下 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.准备:
集群部署规划:
kafka集群设置shell脚本一键启动
采用shell脚本启动kafka
- 首先新建文件 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集群设置shell脚本一键关闭
采用shell脚本启动kafka
- 首先新建文件 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