[KAFKA-10186] Aborting transaction with pending data should throw non-fatal exception

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.7.0
• Component/s: producer
• Labels: needs-kip newbie newbie++
• Assignee: Gokul Srinivas
• Reporter: A. Sophie Blee-Goldman
• Created: 18/Jun/20 22:27
• Updated: 07/Oct/20 16:35
• Resolved: 07/Oct/20 16:35

Description

Currently if you try to abort a transaction with any pending (non-flushed) data, the send exception is set to

 KafkaException("Failing batch since transaction was aborted")

This exception type is generally considered fatal, but this is a valid state to be in – the point of throwing the exception is to alert that the records will not be sent, not that you are in an unrecoverable error state.

We should throw a different (possibly new) type of exception here to distinguish from fatal and recoverable errors.

Issue Links

• causes: KAFKA-10169 KafkaException: Failing batch since transaction was aborted
• links to: GitHub Pull Request #9280
• mentioned in: Page Loading...