[KAFKA-5260] Producer should not send AbortTxn unless transaction has actually begun

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 0.11.0.0
• Component/s: clients, core, producer
• Labels: exactly-once
• Assignee: Damian Guy
• Reporter: Jason Gustafson
• Created: 16/May/17 23:20
• Updated: 30/May/17 05:57
• Resolved: 30/May/17 05:57

Description

When there is an authorization error in AddOffsets or AddPartitions, the producer will raise an authorization exception. When that happens, the user should abort the transaction. The problem is that in an authorization error, the coordinator will not have transitioned to a new state, so if it suddenly receives an AbortTxnRequest, that request will fail with an InvalidTxnState, which will be propagated to the error. The suggested solution is to keep track locally when we are certain that no transaction has been officially begun and to skip sending the AbortTxnRequest in that case.

Issue Links

• links to: GitHub Pull Request #3126