Xinyu Liu created SAMZA-1003:
--------------------------------
Summary: Restore the lazy init for kafka system producer
Key: SAMZA-1003
URL: https://issues.apache.org/jira/browse/SAMZA-1003
Project: Samza
Issue Type: Bug
Affects Versions: 0.11
Reporter: Xinyu Liu
Assignee: Xinyu Liu
Priority: Blocker
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
