commit 6c13fca51fb8b25e6bfe4b3ab416e774ab9142ac
author Gwen Shapira <cshapi@gmail.com> Mon Apr 11 16:08:46 2016 -0700
committer Gwen Shapira <cshapi@gmail.com> Mon Apr 11 16:08:46 2016 -0700
tree b130155a93e1dce34991d1591fc59c2148cb5644
parent 0773bc4ba604bc8b57040583ac4c1cb6832ba188
parent 40fd456649b5df29d030da46865b5e7e0ca6db15

Merge branch 'trunk' into 0.10.0

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 a02cfb4..97a7aac 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
@@ -243,6 +243,8 @@
 
         topology.addProcessor(name, new KStreamForeach<>(action), this.name);
     }
+
+    @Override
     public KStream<K, V> through(Serde<K> keySerde, Serde<V> valSerde, String topic) {
         return through(keySerde, valSerde, null, topic);
     }