Xinyu Liu created SAMZA-979:
-------------------------------
Summary: Fix for KafkaCheckpointMigration not registering source
correctly
Key: SAMZA-979
URL: https://issues.apache.org/jira/browse/SAMZA-979
Project: Samza
Issue Type: Bug
Affects Versions: 0.11
Reporter: Xinyu Liu
Assignee: Xinyu Liu
Priority: Blocker
After the thread-safe kafka producer change, all producer need to register the
source before publishing to it. The registering of KafkaCheckpointMigration
happens in the wrong place. Move it after the producer is created.
Also find an extra logging introduced by the change. Remove it during this fix.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
