31 lines
1.1 KiB
Bash
Executable File
31 lines
1.1 KiB
Bash
Executable File
#!/bin/sh
|
||
|
||
#修改BASE_DIR为安装的路径
|
||
#启动命令端口可自行指定
|
||
#JMX_PORT=9191 nohup $BASE_DIR/bin/kafka-server-start.sh $BASE_DIR/config/server.properties > /dev/null 2>&1 &
|
||
|
||
PRO_NAME=Kafka
|
||
BASE_DIR=$1
|
||
VERSION="kafka_2.11-1.0.0"
|
||
|
||
#string=`cat $BASE_DIR/$VERSION/config/server.properties | grep broker.id`
|
||
#array=(${string//=/ })
|
||
#echo ${array[1]}
|
||
#ssh root@192.168.40.123 "source /etc/profile ; zkCli.sh ls /kafka/brokers/ids | grep -v 2181 | grep 4 | wc -l"
|
||
source /etc/profile
|
||
while true ; do
|
||
NUM=`jps | grep -w ${PRO_NAME} | grep -v grep |wc -l`
|
||
|
||
if [ "${NUM}" -lt "1" ];then
|
||
JMX_PORT=9191 nohup $BASE_DIR/$VERSION/bin/kafka-server-start.sh $BASE_DIR/$VERSION/config/server.properties > /dev/null 2>&1 &
|
||
OLD_NUM=`cat $BASE_DIR/$VERSION/logs/restart_sum.log`
|
||
RESTART_NUM=`expr $OLD_NUM + 1`
|
||
echo $RESTART_NUM > $BASE_DIR/$VERSION/logs/restart_sum.log
|
||
echo "`date "+%Y-%m-%d %H:%M:%S"` - kafka服务启动/异常重启 - 重启次数 -> $RESTART_NUM" >> $BASE_DIR/$VERSION/restart.log
|
||
#大于1，杀掉所有进程，重启
|
||
elif [ "${NUM}" -gt "1" ];then
|
||
killall -9 ${PRO_NAME}
|
||
fi
|
||
sleep 60
|
||
done
|