Description
Currently ConsumerCoordinator's OffsetFetchResponseHandler only retries on COORDINATOR_LOAD_IN_PROGRESS and NOT_COORDINATOR errors.
The error handling should be expanded to retry on all retriable errors.
Attachments
Issue Links
- is related to
-
KAFKA-17294 Handle retriable errors when fetching offsets in new consumer
- Resolved
- relates to
-
KAFKA-17267 New group coordinator can return REQUEST_TIMED_OUT for OFFSET_FETCHes
- Resolved
- links to