diff --git a/kafka-rest/src/main/java/io/confluent/kafkarest/v2/KafkaConsumerState.java b/kafka-rest/src/main/java/io/confluent/kafkarest/v2/KafkaConsumerState.java index 2f99fd5bd9..14cff93455 100644 --- a/kafka-rest/src/main/java/io/confluent/kafkarest/v2/KafkaConsumerState.java +++ b/kafka-rest/src/main/java/io/confluent/kafkarest/v2/KafkaConsumerState.java @@ -341,13 +341,13 @@ synchronized Optional getOffsetForTime(String topic, int partition, Instan .map(OffsetAndTimestamp::offset); } - public synchronized boolean expired(Instant now) { + public boolean expired(Instant now) { synchronized (this.expirationLock) { return !expiration.isAfter(now); } } - public synchronized void updateExpiration() { + public void updateExpiration() { synchronized (this.expirationLock) { this.expiration = clock.instant().plus(consumerInstanceTimeout); }