[KAFKA-5147] KafkaProducer's TransactionManager needs a review on synchronization

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 0.11.0.0
• Labels: exactly-once
• Assignee: Apurva Mehta
• Reporter: Apurva Mehta
• Created: 01/May/17 17:41
• Updated: 25/Jul/17 11:11
• Resolved: 25/May/17 23:25

Description

Currently, the completion handlers are not synchronized, though they access shared state like `partitionsInTransaction`, and `lastError`, `pendingPartitionsToBeaddedToTransaction`, etc.

We should either make the collections concurrent or synchronize the handlers.

In general, we need to review this code to ensure that the synchronization is correct.

Issue Links

• links to: GitHub Pull Request #3132