[
https://issues.apache.org/jira/browse/SAMZA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566120#comment-16566120
]
Jake Maes commented on SAMZA-1796:
----------------------------------
[~xinyu], I assume it doesn't create changelog streams because
PassthroughJobCoordinator typically isn't used for stateful jobs, as there's no
guarantee around partition assignment.
Is there some use case where this is needed? Curious how it is intended to
work.
> PassthroughJobCoordinator doesn't create changelog streams
> ----------------------------------------------------------
>
> Key: SAMZA-1796
> URL: https://issues.apache.org/jira/browse/SAMZA-1796
> Project: Samza
> Issue Type: Improvement
> Reporter: Xinyu Liu
> Assignee: Xinyu Liu
> Priority: Major
>
> Currently only the ClusterBasedJobCoordinator and ZkJobCoordinator are
> creating changelog streams. The Passthrough one should also do it.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
