监测kafka-lag值的shell脚本

自己手写了一个监测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分钟执行一次，还没有遇到消息堆积的情况。