Minor: KafkaConfig should treat empty changelog name as no changelog.
authorPrateek Maheshwari <pmaheshwari@linkedin.com>
Wed, 6 Jun 2018 18:00:06 +0000 (11:00 -0700)
committerPrateek Maheshwari <pmaheshwari@linkedin.com>
Wed, 6 Jun 2018 18:00:06 +0000 (11:00 -0700)
commit36c4c4b02df36027fc3516407085175fb565bd70
treedc5a203e5f10865c9f70e4eb47f400acdcd0bc57
parent4c0e50581c3a9473fb4cb09103577e468b0fb439
Minor: KafkaConfig should treat empty changelog name as no changelog.

If a store changelog stream name is empty, treat is as a non-changelogged store instead of throwing an exception.

Author: Prateek Maheshwari <pmaheshwari@linkedin.com>

Reviewers: Jagadish Venkatraman <vjagadish1989@gmail.com>

Closes #546 from prateekm/kafka-changelog
samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala