From df2bf03cb3cc6f0ba1a0ec686bb93bbbaff9b5f5 Mon Sep 17 00:00:00 2001
From: Marcin Grzejszczak <marcin.grzejszczak@gmail.com>
Date: Wed, 13 Oct 2021 16:16:03 +0200
Subject: [PATCH] Fixed compilation issues

---
 .../instrument/kafka/TracingKafkaConsumer.java      | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

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);
+	}
+
 }