[
https://issues.apache.org/jira/browse/SAMZA-979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyu Liu updated SAMZA-979:
----------------------------
Summary: Remove KafkaCheckpointMigration (was: Fix for
KafkaCheckpointMigration not registering source correctly)
> Remove KafkaCheckpointMigration
> -------------------------------
>
> 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)
