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