root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

HOTFIX: correct sourceNodes for kstream.through() 

guozhangwang

Author: Yasuhiro Matsuda <yasuhiro@confluent.io>

Reviewers: Guozhang Wang

Closes #374 from ymatsuda/fix_through_operator
This commit is contained in:
Yasuhiro Matsuda 2015-10-27 16:26:47 -07:00 committed by Guozhang Wang
parent 0b05d3b939
commit 13c3e049fb
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
View File

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