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 0b4b5e97..a787e0f5 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 @@ -1605,6 +1605,7 @@ public class KafkaMessageListenerContainer // NOSONAR line count ListenerUtils.stoppableSleep(KafkaMessageListenerContainer.this, duration.toMillis()); } catch (InterruptedException e) { + Thread.currentThread().interrupt(); this.logger.error(e, "Interrupted while sleeping"); } }