From 536ebf13e5f95362384661e3987dad108f874f47 Mon Sep 17 00:00:00 2001
From: ETBoye <6248524+ETBoye@users.noreply.github.com>
Date: Fri, 28 Nov 2025 09:34:47 +0100
Subject: [PATCH] Update KafkaConsumerTelemetry.java

---
 .../kafkaclients/v2_6/internal/KafkaConsumerTelemetry.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/internal/KafkaConsumerTelemetry.java b/instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/internal/KafkaConsumerTelemetry.java
index 97debc510193..ed6db3550485 100644
--- a/instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/internal/KafkaConsumerTelemetry.java
+++ b/instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/main/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/internal/KafkaConsumerTelemetry.java
@@ -54,7 +54,7 @@ public <K, V> ConsumerRecords<K, V> addTracing(
       }
       records.put(partition, list);
     }
-    return new ConsumerRecords<>(records);
+    return new ConsumerRecords<>(records, consumerRecords.nextOffsets());
   }
 
   public <K, V> Context buildAndFinishSpan(