监测kafka lag值的shell脚本

2020年11月11日 182点热度 0条评论 来源: SyntaxError

自己手写了一个监测kafka lag值的shell脚本。之前是用python写的,感觉比较麻烦,这里写了一个shell版的,大家可以直接拿来使用。

cd /usr/share/kafka/kafka_2.11-2.4.1/ || exit 1
lag=$(./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my_group 2>/dev/null|grep -v GROUP|awk 'NR>1{num+=$6}END{print num}')
echo "$lag"
if [ "$lag" -gt 10 ];then
  echo "lag值过大"
  #或者mail或者send_ding_msg,自行设置
fi

下面是执行情况。

最后可以将这个脚本添加到crontab定时任务,我目前是每10分钟执行一次,还没有遇到消息堆积的情况。

    原文作者:SyntaxError
    原文地址: https://segmentfault.com/a/1190000023040259
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。