[KAFKA-6122] Global Consumer should handle TimeoutException

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.1.0
• Component/s: streams
• Labels: needs-kip streams-exception-handling streams-resilience
• Assignee: Matthias J. Sax
• Reporter: Matthias J. Sax
• Created: 25/Oct/17 23:02
• Updated: 12/Jan/18 19:38
• Resolved: 18/Nov/17 22:55

Description

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.

https://cwiki.apache.org/confluence/display/KAFKA/KIP-224%3A+Add+configuration+parameters+%60retries%60+and+%60retry.backoff.ms%60+to+Streams+API

Issue Links

• is required by: KAFKA-6124 Revisit default config for internal client with regard to resilience
• relates to: KAFKA-5301 Improve exception handling on consumer path
• links to: GitHub Pull Request #4206
• mentioned in: Page Loading...