Skip to content

Commit

Permalink
feat: restart kafka when it failed
Browse files Browse the repository at this point in the history
  • Loading branch information
yunnysunny committed Aug 15, 2024
1 parent f03f9b7 commit 2bd943f
Showing 1 changed file with 8 additions and 4 deletions.
12 changes: 8 additions & 4 deletions start_kafka.sh
Original file line number Diff line number Diff line change
Expand Up @@ -4,16 +4,20 @@ rm -rf /var/run/kafka/kafka.pid
/data/config.sh

/etc/init.d/kafka start

while true
RESTART_THRESHOLD=${RESTART_THRESHOLD:-10}
RESTART_COUNT=0
while [ $RESTART_COUNT -le "$RESTART_THRESHOLD" ]
do
PID=$(cat $KAFKA_PIDFILE)
if ps -p $PID > /dev/null
then
sleep 1
else
echo "kafka not running"
DATE=$(date '+%Y-%m-%d %H:%M:%S')
echo "${DATE} ===kafka not running==="
tail -100 /data/app/log/server.log
exit 1
RESTART_COUNT=$((RESTART_COUNT+1))
echo "===restart kafka=== $RESTART_COUNT"
fi
done
exit 1

0 comments on commit 2bd943f

Please sign in to comment.