diff --git a/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaConsumer.java b/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaConsumer.java
index 4e655899e..d526a3cb5 100644
--- a/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaConsumer.java
+++ b/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaConsumer.java
@@ -20,8 +20,8 @@ import java.time.Duration;
 import java.util.Collection;
 import java.util.List;
 import java.util.Map;
+import java.util.OptionalLong;
 import java.util.Set;
-import java.util.concurrent.TimeUnit;
 import java.util.regex.Pattern;
 
 import org.apache.kafka.clients.consumer.Consumer;
@@ -316,12 +316,6 @@ public class TracingKafkaConsumer<K, V> implements Consumer<K, V> {
 		this.delegate.close();
 	}
 
-	@Override
-	@Deprecated
-	public void close(long l, TimeUnit timeUnit) {
-		this.delegate.close(l, timeUnit);
-	}
-
 	@Override
 	public void close(Duration duration) {
 		this.delegate.close(duration);
@@ -332,4 +326,9 @@ public class TracingKafkaConsumer<K, V> implements Consumer<K, V> {
 		this.delegate.wakeup();
 	}
 
+	@Override
+	public OptionalLong currentLag(TopicPartition topicPartition) {
+		return this.delegate.currentLag(topicPartition);
+	}
+
 }