我正在使用Kafka general dashboard for grafana https://grafana.com/grafana/dashboards/11962-kafka-metrics/ prometheus数据源
我有一个消费者滞后查询面板:sum(Kafka_consumergroup_lag)by(consumergroup)特定消费者组警报查询:sum(Kafka_consumergroup_lag{consumergroup=“CONSUMER_GRP_NAME”})by(consumergroup)
现在我需要一个grafana警报时,总和(计数)是相同的X分钟
场景:对于CONSUMER_GRP_NAME,如果计数为1500(例如),则在X分钟内保持不变。我的目标是确定在X分钟内未处理的时间,我需要警报
1条答案
按热度按时间wixjitnu1#
例如:sum_over_time(Kafka_consumergroup_group_sum_lag{group=~"(Q..-000)..*",group!~".*Local”}[120m])