From 225ae34ae782d8cf72e4583dd0d3142d05fd5adc Mon Sep 17 00:00:00 2001
From: Etienne Guerlais <etienne.guerlais@ricardo.ch>
Date: Thu, 17 Aug 2023 15:38:35 +0200
Subject: [PATCH] Fix the name of 2 consumer metrics

---
 instrumenting.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/instrumenting.go b/instrumenting.go
index 992b24e..2728e5c 100644
--- 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)