[SAMZA-1638] Recreate SystemProducer on KafkaCheckpointManager.writeCheckpoint failure.

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.1
• Assignee: Shanthoosh Venkataraman
• Reporter: Shanthoosh Venkataraman
• Created: 04/Apr/18 19:57
• Updated: 07/Mar/19 01:10
• Resolved: 05/Dec/18 17:31

Description

Retry loop in the KafkaCheckpointManager implementation currently reuses the same SystemProducer instance on exception and does not recreate it.

When some irrecoverable exceptions are thrown by the producer, all subsequent operations on that instance will fail there by making the retry loop pointless.

 

Issue Links

• links to: GitHub Pull Request #792