[kafkametricsreceiver] Fix issue with incorrect consumer offset

open-telemetry · Jul 3, 2024 · b915542 · b915542
1 parent 62ea24b
commit b915542
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/receiver/kafkametricsreceiver/consumer_scraper.go b/receiver/kafkametricsreceiver/consumer_scraper.go
@@ -142,7 +142,7 @@ func (s *consumerScraper) scrape(context.Context) (pmetric.Metrics, error) {
 				for partition, block := range partitions {
 					consumerOffset := block.Offset
 					offsetSum += consumerOffset
-					s.mb.RecordKafkaConsumerGroupOffsetDataPoint(now, offsetSum, group.GroupId, topic, int64(partition))
+					s.mb.RecordKafkaConsumerGroupOffsetDataPoint(now, consumerOffset, group.GroupId, topic, int64(partition))
 
 					// default -1 to indicate no lag measured.
 					var consumerLag int64 = -1