Repository: kafka Updated Branches: refs/heads/trunk 0b05d3b93 -> 13c3e049f
HOTFIX: correct sourceNodes for kstream.through() guozhangwang Author: Yasuhiro Matsuda <yasuh...@confluent.io> Reviewers: Guozhang Wang Closes #374 from ymatsuda/fix_through_operator Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/13c3e049 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/13c3e049 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/13c3e049 Branch: refs/heads/trunk Commit: 13c3e049fbf22522c90c2a0b4b4f680b974d9bea Parents: 0b05d3b Author: Yasuhiro Matsuda <yasuh...@confluent.io> Authored: Tue Oct 27 16:26:47 2015 -0700 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Tue Oct 27 16:26:47 2015 -0700 ---------------------------------------------------------------------- .../org/apache/kafka/streams/kstream/internals/KStreamImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/13c3e049/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java ---------------------------------------------------------------------- diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java index 404193a..1a2297c 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java @@ -178,7 +178,7 @@ public class KStreamImpl<K, V> implements KStream<K, V> { topology.addSource(sourceName, keyDeserializer, valDeserializer, topic); - return new KStreamImpl<>(topology, sourceName, Collections.<String>emptySet()); + return new KStreamImpl<>(topology, sourceName, Collections.singleton(sourceName)); } @Override
