写了一个shell脚本来手工监控kafka滞后值。之前是用python写的，感觉很繁琐。这里有一个shell版本，你可以直接使用。cd/usr/share/kafka/kafka_2.11-2.4.1/||退出1lag=$(./bin/kafka-consumer-groups.sh--bootstrap-serverlocalhost:9092--describe--groupmy_group2>/dev/null|grep-vGROUP|awk'NR>1{num+=$6}END{printnum}')echo"$lag"if["$lag"-gt10];thenecho"lagvalueoverBig"#或者mail或者send_ding_msg，fi自己设置下面是实现。最后把这个脚本加入到crontab定时任务中即可。我目前是每10分钟执行一次，还没有遇到过消息堆积的情况。
