[ 
https://issues.apache.org/jira/browse/SAMZA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567321#comment-16567321
 ] 

Jake Maes commented on SAMZA-1796:
----------------------------------

[~bharathkk] hmm, ok. 

But it still begs the question; why is PassthroughJobCoordinator being used 
with a stateful job? If that combination doesn't make sense, then the only 
reason we'd only be adding the topic creation for consistency. But it gives the 
illusion that stateful processing is supported with passthrough, which can 
perpetuate bad practices. 

> 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)

Reply via email to