You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/04/12 20:34:49 UTC
kafka git commit: MINOR: Add missing `@Override` to
`KStreamImpl.through`
Repository: kafka
Updated Branches:
refs/heads/trunk 40fd45664 -> 319c6e719
MINOR: Add missing `@Override` to `KStreamImpl.through`
Author: Ismael Juma <is...@juma.me.uk>
Reviewers: Guozhang Wang <wa...@gmail.com>
Closes #1216 from ijuma/add-missing-override-to-through
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/319c6e71
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/319c6e71
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/319c6e71
Branch: refs/heads/trunk
Commit: 319c6e7195143c1fa4a1e5b34ad923c2b73f373d
Parents: 40fd456
Author: Ismael Juma <is...@juma.me.uk>
Authored: Tue Apr 12 11:34:46 2016 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Tue Apr 12 11:34:46 2016 -0700
----------------------------------------------------------------------
.../org/apache/kafka/streams/kstream/internals/KStreamImpl.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/319c6e71/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 @@ public class KStreamImpl<K, V> extends AbstractStream<K> implements KStream<K, V
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);
}