[
https://issues.apache.org/jira/browse/SAMZA-979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyu Liu updated SAMZA-979:
----------------------------
Description:
KafkaCheckpointMigration is not needed anymore for ver 11. remove the code.
Also find an extra logging introduced by the change. Remove it during this fix.
was:
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.
> 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
>
> KafkaCheckpointMigration is not needed anymore for ver 11. remove the code.
> 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)
