[KAFKA-8729] Augment ProduceResponse error messaging for specific culprit records

• Type: Improvement
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Component/s: clients, core
• External issue URL: https://cwiki.apache.org/confluence/display/KAFKA/KIP-467%3A+Augment+ProduceResponse+error+messaging+for+specific+culprit+records
• Assignee: Tu Tran
• Reporter: Guozhang Wang
• Created: 29/Jul/19 16:36
• Updated: 28/Jan/20 21:57

Description

1. We should replace the misleading CORRUPT_RECORD error code with a new INVALID_RECORD.

2. We should augment the ProduceResponse with customizable error message and indicators of culprit records.

3. We should change the client-side handling logic of non-retriable INVALID_RECORD to re-batch the records.

Details see: https://cwiki.apache.org/confluence/display/KAFKA/KIP-467%3A+Augment+ProduceResponse+error+messaging+for+specific+culprit+records

Issue Links

• links to: GitHub Pull Request #7142
• links to: GitHub Pull Request #7150
• links to: GitHub Pull Request #7167
• links to: GitHub Pull Request #7168
• links to: GitHub Pull Request #7522
• links to: GitHub Pull Request #7612
• mentioned in: Page Loading...
• mentioned in: Page Loading...
• mentioned in: Page Loading...