Global consumer does not handle TimeoutException that might be throw by partitonsFor() and endOffsets(). This affect the bootstrapping phase only.
We need to allow for a proper retry strategy, with configurable max number of retries and back off time between retries. We might need to introduce new configuration parameters – for this case, we need to do a KIP.
- is required by
-
KAFKA-6124 Revisit default config for internal client with regard to resilience
-
- Resolved
-
- relates to
-
KAFKA-5301 Improve exception handling on consumer path
-
- Resolved
-
- links to
- mentioned in
-
Page Loading...