This is an automated email from the ASF dual-hosted git repository.
lianetm 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 9956b49816d KAFKA-20652: a couple of java-doc typo fixing (#22455)
9956b49816d is described below
commit 9956b49816deb77e5d022f2a42505bd9cfe23fc9
Author: Jess668 <[email protected]>
AuthorDate: Tue Jun 2 18:47:08 2026 -0500
KAFKA-20652: a couple of java-doc typo fixing (#22455)
fix: correct javadoc typos
- Produced.java:117: fix @param description for valueSerde (was 'key',
should be 'value')
- WindowStore, ReadOnlyWindowStore, SegmentedBytesStore: fix 'within in'
→ 'within the' (4 occurrences)
- JoinWindows.java:157: remove stray closing brace in {@link} tag
Reviewers: Alieh Saeedi <[email protected]>, Lianet Magrans
<[email protected]>
---
.../src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java | 2 +-
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java | 2 +-
.../main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java | 4 ++--
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java | 2 +-
.../org/apache/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 4690ffdfe7c..80db8f5624b 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 class JoinWindows extends Windows<Window> {
* @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 cb0eb856386..90fd535fc3b 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 class Produced<K, V> implements
NamedOperation<Produced<K, V>> {
/**
* 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 ceb0c43f3c7..f8dff981814 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 @@ public interface ReadOnlyWindowStore<K, V> {
}
/**
- * 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 @@ public interface ReadOnlyWindowStore<K, V> {
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 d01d08dcb39..04cbaf96a00 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 @@ public interface WindowStore<K, V> extends StateStore,
ReadOnlyWindowStore<K, V>
}
/**
- * 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 957867d21ff..ce24e1eb0a6 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)
