[KAFKA-5251] Producer should drop queued sends when transaction is aborted

• 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: Jason Gustafson
• Reporter: Jason Gustafson
• Created: 15/May/17 21:21
• Updated: 31/May/17 03:56
• Resolved: 31/May/17 03:54

Description

As an optimization, if a transaction is aborted, we can drop any records which have not yet been sent to the brokers. However, to avoid the sequence number getting out of sync, we need to continue sending any request which has been sent at least once.

Issue Links

• links to: GitHub Pull Request #3161