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

Restore lazy init for kafka system producer

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • 0.11.0
    • 0.11.0
    • None
    • 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

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

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

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment