SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed compilation issues

Browse Source
This commit is contained in:
Marcin Grzejszczak
2021-10-13 16:16:03 +02:00
parent 3dc8387a6f
commit df2bf03cb3
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/kafka/TracingKafkaConsumer.java
View File

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