[ https://issues.apache.org/jira/browse/SAMZA-1638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Prateek Maheshwari resolved SAMZA-1638. --------------------------------------- Resolution: Fixed > Recreate SystemProducer on KafkaCheckpointManager.writeCheckpoint failure. > -------------------------------------------------------------------------- > > Key: SAMZA-1638 > URL: https://issues.apache.org/jira/browse/SAMZA-1638 > Project: Samza > Issue Type: Bug > Reporter: Shanthoosh Venkataraman > Assignee: Shanthoosh Venkataraman > Priority: Major > > 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. > -- This message was sent by Atlassian JIRA (v7.6.3#76005)