Boris Shkolnik created SAMZA-1076:
-------------------------------------
Summary: getKafkaChangelogEnabledStores() should use
StorageConfig.getChangelogStream to get changelog system.stream
Key: SAMZA-1076
URL: https://issues.apache.org/jira/browse/SAMZA-1076
Project: Samza
Issue Type: Bug
Reporter: Boris Shkolnik
Assignee: Boris Shkolnik
Currently it gets the value for changelog directly from the config and tries to
parse it assuming format 'system.stream'. But since Samza-1060, changelog could
be in format 'stream' (if job.changelog.system setting is present).
getKafkaChangelogEnabledStores needs to use StorageConfig.getChangelog to
account for the possibility instead of getting it directly.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
