Details
-
Bug
-
Status: Patch Available
-
Major
-
Resolution: Unresolved
-
3.8.0
Description
While running some stress tests we found out consumers were not leaving the group if interrupted while closing (leading to members getting eventually fenced after the session expired). On close, the consumer generates an Unsubscribe event to be handled in the background, but we noticed that the network thread failed with the interruption, seemingly not sending the unsent requests. We should review this to ensure that a member does a clean leave, notifying the coordinator with a leave HB, even if in a fire-and-forget mode in the case of interruption (and validate the legacy consumer behaviour in this scenario). (Still under investigation, I'll update more info as I discover it)
Attachments
Issue Links
- relates to
-
KAFKA-17518 AsyncKafkaConsumer cannot reliably leave group when closed with small timeout
- Open
-
KAFKA-17519 Define and validate correctness of Consumer.close() and its timeout when thread is interrupted
- Open
- links to