From 5df71c169a366bee623780a9b99a36f3055b485c Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Wed, 9 Nov 2022 14:43:03 -0500 Subject: [PATCH] Fix Missing Re-Interrupt --- .../kafka/listener/KafkaMessageListenerContainer.java | 1 + 1 file changed, 1 insertion(+) 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"); } }