(kafka) branch trunk updated: MINOR: Update docs link to deprecated method TimeWindows.grace (#15700)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chia7712 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 753cc4b7c87 MINOR: Update docs link to deprecated method TimeWindows.grace (#15700)
753cc4b7c87 is described below

commit 753cc4b7c872f3d3d42d47be8ff1c65003e5488c
Author: Ayoub Omari <ay...@outlook.fr>
AuthorDate: Fri Apr 12 05:16:10 2024 +0200

    MINOR: Update docs link to deprecated method TimeWindows.grace (#15700)
    
    Reviewers: Chia-Ping Tsai <ch...@gmail.com>
---
 .../apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java   | 2 +-
 .../org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java b/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java
index 633372f788a..dc672e95eb6 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java
@@ -39,7 +39,7 @@ import java.time.Duration;
  * materialized view) that can be queried using the name provided in the {@link Materialized} instance.
  * Furthermore, updates to the store are sent downstream into a windowed {@link KTable} changelog stream, where
  * "windowed" implies that the {@link KTable} key is a combined key of the original record key and a window ID.
- * New events are added to sessions until their grace period ends (see {@link SessionWindows#grace(Duration)}).
+ * New events are added to sessions until their grace period ends (see {@link SessionWindows#ofInactivityGapAndGrace(Duration, Duration)}).
  * <p>
  * A {@code SessionWindowedCogroupedKStream} must be obtained from a {@link CogroupedKStream} via
  * {@link CogroupedKStream#windowedBy(SessionWindows)}.
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java b/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java
index 582f7f57b77..9944da99b5f 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java
@@ -41,7 +41,7 @@ import java.time.Duration;
  * materialized view) that can be queried using the name provided in the {@link Materialized} instance.
  * Furthermore, updates to the store are sent downstream into a windowed {@link KTable} changelog stream, where
  * "windowed" implies that the {@link KTable} key is a combined key of the original record key and a window ID.
- * New events are added to windows until their grace period ends (see {@link TimeWindows#grace(Duration)}).
+ * New events are added to windows until their grace period ends (see {@link TimeWindows#ofSizeAndGrace(Duration, Duration)}).
  * <p>
  * A {@code TimeWindowedCogroupedKStream} must be obtained from a {@link CogroupedKStream} via
  * {@link CogroupedKStream#windowedBy(Windows)}.