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 85d20de2..a07104d7 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 @@ -888,7 +888,6 @@ public class KafkaMessageListenerContainer // NOSONAR line count while (isRunning()) { try { pollAndInvoke(); - idleBetweenPollIfNecessary(); } catch (@SuppressWarnings(UNUSED) WakeupException e) { // Ignore, we're stopping or applying immediate foreign acks @@ -929,6 +928,7 @@ public class KafkaMessageListenerContainer // NOSONAR line count if (!this.autoCommit && !this.isRecordAck) { processCommits(); } + idleBetweenPollIfNecessary(); if (this.seeks.size() > 0) { processSeeks(); }