[KAFKA-8805] Bump producer epoch following recoverable errors

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.3.0
• Fix Version/s: 2.5.0
• Component/s: producer
• Assignee: Bob Barrett
• Reporter: Bob Barrett
• Created: 14/Aug/19 19:44
• Updated: 06/Apr/20 22:49
• Resolved: 16/Feb/20 06:59

Description

As part of KIP-360, the producer needs to call the new InitProducerId API after receiving UNKNOWN_PRODUCER_ID and INVALID_PRODUCER_MAPPING errors, which will allow the producers to bump their epoch and continue processing unless a new producer has already initialized a new producer ID.

The broker change that this depends on is https://issues.apache.org/jira/browse/KAFKA-8710.

Issue Links

• links to: GitHub Pull Request #7389
• mentioned in: Page Loading...