Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
In the async consumer, the coordinator isn't being removed when receiving the following exception:
(e instanceof DisconnectException) { markCoordinatorUnknown(true, e.getMessage()); }
This should happen on all requests going to coordinator node:
1. heartbeat 2. offset fetch/commit
Attachments
Issue Links
- is part of
-
KAFKA-14246 Update threading model for Consumer
- Resolved