[kafka] branch trunk updated: MINOR: Fixed type in KTable JavaDocs(#6867)

[mj...@apache.org]

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 <1h...@gmail.com>
AuthorDate: Thu Dec 29 05:36:59 2022 +0530

    MINOR: Fixed type in KTable JavaDocs(#6867)
    
    Reviewers: Matthias J. Sax <ma...@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();
      *     }