Fix missing value of "lagObserved"

Metric only being set if there are values, which leads to an artifacts of the metrics. Set it when there are no metrics as well.
lwolf · Nov 17, 2022 · 2f44d34 · 2f44d34
1 parent 5370864
commit 2f44d34
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/providers/prometheus.go b/pkg/providers/prometheus.go
@@ -125,6 +125,7 @@ func (l *PrometheusMP) GetLagByPartition(partition int32) time.Duration {
 	behind := l.GetMessagesBehind(partition)
 	production := l.GetProductionRate(partition)
 	if production == 0 {
+		lagObserved.WithLabelValues(l.consumer, strconv.Itoa(int(partition))).Set(0)
 		return 0
 	}
 	lagM := float64(behind) / float64(production)