Skip to content

Commit 8c15f7d

Browse files
committed
Fix Missing Re-Interrupt
1 parent 42f654d commit 8c15f7d

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1660,6 +1660,7 @@ private void sleepFor(Duration duration) {
16601660
ListenerUtils.stoppableSleep(KafkaMessageListenerContainer.this, duration.toMillis());
16611661
}
16621662
catch (InterruptedException e) {
1663+
Thread.currentThread().interrupt();
16631664
this.logger.error(e, "Interrupted while sleeping");
16641665
}
16651666
}

0 commit comments

Comments
 (0)