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 95f90548..daa41eff 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 @@ -817,7 +817,7 @@ public class KafkaMessageListenerContainer // NOSONAR line count private boolean taskSchedulerExplicitlySet; - private long lastReceive = System.currentTimeMillis(); + private long lastReceive; private long lastAlertAt = this.lastReceive; @@ -1389,6 +1389,7 @@ public class KafkaMessageListenerContainer // NOSONAR line count initialize(); Throwable exitThrowable = null; boolean failedAuthRetry = false; + this.lastReceive = System.currentTimeMillis(); while (isRunning()) { try { pollAndInvoke();