Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Duplicate
-
None
-
None
-
None
-
None
Description
org.apache.kafka.common.utils.SystemTime.sleep() catches and ignores InterruptedException. When doing so normally the interruption state should still be restored with Thread.currentThread().interrupt().
Attachments
Issue Links
- duplicates
-
KAFKA-4375 Kafka consumer may swallow some interrupts meant for the calling thread
- Resolved