[KAFKA-6120] RecordCollectorImpl should not retry sending

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.1.0
• Component/s: streams
• Labels: streams-exception-handling streams-resilience
• Assignee: Matthias J. Sax
• Reporter: Matthias J. Sax
• Created: 25/Oct/17 22:47
• Updated: 06/Nov/17 18:52
• Resolved: 06/Nov/17 18:51

Description

Currently, RecordCollectorImpl implements an internal retry loop for sending data with a hard coded retry maximum. This raises the problem, that data might be send out-of-order while at the same time, does not improve the overall resilience much, as the number of retires is hardcoded.

Thus, we should remove this loop and only rely an producer configuration parameter retires that uses can configure accordingly.

Issue Links

• links to: GitHub Pull Request #4148