Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
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.