欢迎光临
我们一直在努力

kafka如何实现重启、自启

#!/bin/sh
#ps -ef | grep $proc_name | grep -v grep | awk '{print $2}'
source /etc/profile
proc_dir="/data/modules/kafka_2.12-1.1.1"    # 程序目录
proc_name="kafka.Kafka"                      # 进程名
file_name="/data/lzmhtest/crontab/kafka/kafka.log"     # 日志文件

number=ps -ef | grep $proc_name | grep -v grep | wc -l
PIDS=$(ps ax | grep $proc_name | grep java | grep -v grep | awk '{print $1}')
if [ $number -eq 0 ]                                    # 判断进程是否存在
then
        #cd /data/modules/kafka_2.12-1.1.1/bin
        sh $proc_dir/bin/kafka-server-start.sh -daemon $proc_dir/config/server.properties     # 重启进程
        pid=$(ps ax | grep $proc_name | grep java | grep -v grep | awk '{print $1}')   #获取新进程号
        echo "服务出现异常.正在重启中…" [$(date +'%F %H:%M:%S')]  >> $file_name
        echo "服务启动完成" PID: $pid [$(date +'%F %H:%M:%S')] >> $file_name # 将新进程号和重启时间记录
else
        echo "kafka正常运行" [$(date +'%F %H:%M:%S')] "pid:" $PIDS  >> $file_name
fi

底下是cronta定时脚本;我写的是每1分钟巡检一次

/1 * lzmhqa /bin/sh /data/lzmhtest/crontab/kafka/kafka.sh

赞(0)
【声明】:本博客不参与任何交易,也非中介,仅记录个人感兴趣的主机测评结果和优惠活动,内容均不作直接、间接、法定、约定的保证。访问本博客请务必遵守有关互联网的相关法律、规定与规则。一旦您访问本博客,即表示您已经知晓并接受了此声明通告。