From 015fa099c75ea58117d34460db0584af98c07027 Mon Sep 17 00:00:00 2001
From: Jess Jin <jejin@confluent.io>
Date: Tue, 2 Jun 2026 10:33:14 -0400
Subject: [PATCH] KAFKA-20652: a couple of java-doc typo fixing

---
 .../java/org/apache/kafka/streams/kstream/JoinWindows.java    | 2 +-
 .../main/java/org/apache/kafka/streams/kstream/Produced.java  | 2 +-
 .../org/apache/kafka/streams/state/ReadOnlyWindowStore.java   | 4 ++--
 .../main/java/org/apache/kafka/streams/state/WindowStore.java | 2 +-
 .../kafka/streams/state/internals/SegmentedBytesStore.java    | 2 +-
 5 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java b/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java
index 4690ffdfe7c47..80db8f5624bd3 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java
@@ -154,7 +154,7 @@ public static JoinWindows ofTimeDifferenceWithNoGrace(final Duration timeDiffere
      * @param timeDifference join window interval
      * @return a new JoinWindows object with the window definition with and grace period (default to 24 hours minus {@code timeDifference})
      * @throws IllegalArgumentException if {@code timeDifference} is negative or can't be represented as {@code long milliseconds}
-     * @deprecated Since 3.0. Use {@link #ofTimeDifferenceWithNoGrace(Duration)}} instead.
+     * @deprecated Since 3.0. Use {@link #ofTimeDifferenceWithNoGrace(Duration)} instead.
      */
     @Deprecated
     public static JoinWindows of(final Duration timeDifference) throws IllegalArgumentException {
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java
index cb0eb85638682..90fd535fc3bd2 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java
@@ -114,7 +114,7 @@ public static <K, V> Produced<K, V> keySerde(final Serde<K> keySerde) {
 
     /**
      * Create a Produced instance with provided valueSerde.
-     * @param valueSerde    Serde to use for serializing the key
+     * @param valueSerde    Serde to use for serializing the value
      * @param <K>           key type
      * @param <V>           value type
      * @return  A new {@link Produced} instance configured with valueSerde
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
index ceb0c43f3c7bb..f8dff98181496 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java
@@ -183,7 +183,7 @@ default KeyValueIterator<Windowed<K>, V> backwardAll() {
     }
 
     /**
-     * Gets all the key-value pairs that belong to the windows within in the given time range.
+     * Gets all the key-value pairs that belong to the windows within the given time range.
      *
      * @param timeFrom the beginning of the time slot from which to search (inclusive), where iteration starts.
      * @param timeTo   the end of the time slot from which to search (inclusive), where iteration ends.
@@ -195,7 +195,7 @@ default KeyValueIterator<Windowed<K>, V> backwardAll() {
     KeyValueIterator<Windowed<K>, V> fetchAll(Instant timeFrom, Instant timeTo) throws IllegalArgumentException;
 
     /**
-     * Gets all the key-value pairs that belong to the windows within in the given time range in backward order
+     * Gets all the key-value pairs that belong to the windows within the given time range in backward order
      * with respect to time (from end to beginning of time).
      *
      * @param timeFrom the beginning of the time slot from which to search (inclusive), where iteration ends.
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java
index d01d08dcb39f9..04cbaf96a0009 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java
@@ -162,7 +162,7 @@ default KeyValueIterator<Windowed<K>, V> backwardFetch(final K keyFrom,
     }
 
     /**
-     * Gets all the key-value pairs that belong to the windows within in the given time range.
+     * Gets all the key-value pairs that belong to the windows within the given time range.
      *
      * @param timeFrom the beginning of the time slot from which to search (inclusive)
      * @param timeTo   the end of the time slot from which to search (inclusive)
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java
index 957867d21ff30..ce24e1eb0a670 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java
@@ -89,7 +89,7 @@ public interface SegmentedBytesStore extends StateStore {
     KeyValueIterator<Bytes, byte[]> backwardAll();
 
     /**
-     * Gets all the key-value pairs that belong to the windows within in the given time range.
+     * Gets all the key-value pairs that belong to the windows within the given time range.
      *
      * @param from the beginning of the time slot from which to search (inclusive)
      * @param to   the end of the time slot from which to search (inclusive)