You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/04/04 19:58:00 UTC

[jira] [Created] (SAMZA-1638) Recreate SystemProducer on KafkaCheckpointManager.writeCheckpoint failure.

Shanthoosh Venkataraman created SAMZA-1638:
----------------------------------------------

             Summary: 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


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)