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

Restore lazy init for kafka system producer

    XMLWordPrintableJSON

    Details

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

      Description

      During the process of making kafka producer thread safe, I refactored the code so the previous lazy init of producer in produce() is moved to start(), resulting all the system registered will start the producer. This is causing backward incompatibility issues since user might have multiple systems defined but only a few of them getting used. Need to restore the lazy init.

        Attachments

        1. SAMZA-1003.0.patch
          1 kB
          Xinyu Liu

          Activity

            People

            • Assignee:
              xinyu Xinyu Liu
              Reporter:
              xinyu Xinyu Liu
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: