This is an automated email from the ASF dual-hosted git repository. mjsax pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push: new 202a8cd2558 MINOR: Fixed type in KTable JavaDocs(#6867) 202a8cd2558 is described below commit 202a8cd25582c47c38778bd2dfa53c9950dad151 Author: Himani Arora <1himani.ar...@gmail.com> AuthorDate: Thu Dec 29 05:36:59 2022 +0530 MINOR: Fixed type in KTable JavaDocs(#6867) Reviewers: Matthias J. Sax <matth...@confluent.io> --- streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java index d1c8623f298..28404eb50bc 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java @@ -663,7 +663,7 @@ public interface KTable<K, V> { * For example, you can compute the new key as the length of the value string. * <pre>{@code * KTable<String, String> table = builder.table("topic"); - * KTable<Integer, String> keyedStream = table.toStream(new KeyValueMapper<String, String, Integer> { + * KStream<Integer, String> keyedStream = table.toStream(new KeyValueMapper<String, String, Integer> { * Integer apply(String key, String value) { * return value.length(); * }