diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java index b0dd1282..99c872c3 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java @@ -766,7 +766,7 @@ public class KafkaMessageListenerContainer // NOSONAR line count private boolean taskSchedulerExplicitlySet; - private long lastReceive = System.currentTimeMillis(); + private long lastReceive; private long lastAlertAt = this.lastReceive; @@ -1299,6 +1299,7 @@ public class KafkaMessageListenerContainer // NOSONAR line count initAssignedPartitions(); publishConsumerStartedEvent(); Throwable exitThrowable = null; + this.lastReceive = System.currentTimeMillis(); while (isRunning()) { try { pollAndInvoke();