Merge pull request #29 from ricardo-ch/fix-metrics

Fix the name of 2 consumer metrics
ricardo-ch · Aug 18, 2023 · 2f4b34e · 2f4b34e
2 parents e3b80ed + 225ae34
commit 2f4b34e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/instrumenting.go b/instrumenting.go
@@ -41,7 +41,7 @@ func getPrometheusRecordConsumedInstrumentation() *prometheus.CounterVec {
 			prometheus.CounterOpts{
 				Namespace: "kafka",
 				Subsystem: "consumer",
-				Name:      "records_consumed_total",
+				Name:      "record_consumed_total",
 				Help:      "Number of records consumed",
 			}, consumerMetricLabels)
 		prometheus.MustRegister(consumerRecordConsumedCounter)
@@ -62,7 +62,7 @@ func getPrometheusRecordConsumedLatencyInstrumentation() *prometheus.HistogramVe
 			prometheus.HistogramOpts{
 				Namespace: "kafka",
 				Subsystem: "consumer",
-				Name:      "record_consumed_latency_seconds",
+				Name:      "record_latency_seconds",
 				Help:      "Total duration in milliseconds",
 			}, consumerMetricLabels)
 		prometheus.MustRegister(consumerRecordConsumedLatency)