Fix the name of 2 consumer metrics

ricardo-ch · Aug 17, 2023 · 225ae34 · 225ae34
1 parent e3b80ed
commit 225ae34
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)