You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2016/07/22 01:15:20 UTC

[jira] [Created] (SAMZA-979) Fix for KafkaCheckpointMigration not registering source correctly

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)