From f111fa756c0ecac3ee10722ccd8d6e1a03c3cc2e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <post@soeren-henning.de>
Date: Sat, 18 Apr 2020 14:07:41 +0200
Subject: [PATCH] Fix Prometheus NaN handling

---
 execution/lag_analysis.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/execution/lag_analysis.py b/execution/lag_analysis.py
index e13895867..40dbe6180 100644
--- a/execution/lag_analysis.py
+++ b/execution/lag_analysis.py
@@ -28,7 +28,7 @@ start = now - timedelta(minutes=5)
 
 response = requests.get('http://kube1.se.internal:32529/api/v1/query_range', params={
     #'query': "sum by(job,topic)(kafka_consumer_consumer_fetch_manager_metrics_records_lag)",
-    'query': "sum by(group, topic)(kafka_consumergroup_group_lag)",
+    'query': "sum by(group, topic)(kafka_consumergroup_group_lag > 0)",
     'start': start.isoformat(),
     'end': end.isoformat(),
     'step': '5s'})
-- 
GitLab