Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1638

Recreate SystemProducer on KafkaCheckpointManager.writeCheckpoint failure.

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.1
    • Component/s: None
    • Labels:
      None

      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.

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                spvenkat Shanthoosh Venkataraman
                Reporter:
                spvenkat Shanthoosh Venkataraman
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: