Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
3.9.0
-
None
Description
The repercussions of a thread's interrupt status on Consumer.close() and its timeout is not well defined. It appears that the ClassicKafkaConsumer will continue to attempt to close all its resources even if an interrupt was triggered prior to—or during—the call to close() though it effectively ignores the user's supplied timeout since each call to NetworkClient.poll() will throw an InterruptException after first making an attempt to poll the socket.
The task here is to review the existing code, verify the behavior with some unit/integration tests, and document it. Furthermore, once the intended behavior has been confirmed, the AsyncKafkaConsumer should be updated to behave likewise.
Attachments
Issue Links
- is related to
-
KAFKA-17518 AsyncKafkaConsumer cannot reliably leave group when closed with small timeout
- Open
-
KAFKA-16985 Ensure consumer sends leave request on close even if interrupted
- Patch Available