From c138436a7dffdca24aff13b11163eddc5b848b74 Mon Sep 17 00:00:00 2001 From: Florin Akermann Date: Tue, 9 Apr 2024 19:56:24 +0200 Subject: [PATCH 1/5] KAFKA-12317: Fix documentation for KStream,KStream left join. --- docs/streams/developer-guide/dsl-api.html | 5 ----- 1 file changed, 5 deletions(-) diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index acd40ad835fec..7126f4e255e44 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -1834,11 +1834,6 @@

The join will be triggered under the conditions listed below whenever new input is received. When it is triggered, the user-supplied ValueJoiner will be called to produce join output records.

-
-
    -
  • Input records with a null key or a null value are ignored and do not trigger the join.
    • -
-

See the semantics overview at the bottom of this section for a detailed description.

From 69d6c400be1356f28636e52781df013ad90d4de3 Mon Sep 17 00:00:00 2001 From: Florin Akermann Date: Tue, 9 Apr 2024 19:58:16 +0200 Subject: [PATCH 2/5] KAFKA-12317: Fix documentation for KStream,KStream outer join. --- docs/streams/developer-guide/dsl-api.html | 5 ----- 1 file changed, 5 deletions(-) diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index 7126f4e255e44..c79f31ff63862 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -1947,11 +1947,6 @@

The join will be triggered under the conditions listed below whenever new input is received. When it is triggered, the user-supplied ValueJoiner will be called to produce join output records.

-
-
    -
  • Input records with a null value are ignored and do not trigger the join.
    • -
-

  • For each input record on one side that does not have any match on the other side, the ValueJoiner will be called with ValueJoiner#apply(leftRecord.value, null) or ValueJoiner#apply(null, rightRecord.value), respectively; this explains the row with timestamp=60, timestamp=80, and timestamp=100 in the table below, which lists [E, null], From bdbef56b6b6781cd2656ec87ef459336fe4a459a Mon Sep 17 00:00:00 2001 From: Florin Akermann Date: Tue, 9 Apr 2024 20:47:43 +0200 Subject: [PATCH 3/5] Revert "KAFKA-12317: Fix documentation for KStream,KStream left join." This reverts commit b14b78f0d5c49ab78a6bd95a32bca5c8eb79d31c. --- docs/streams/developer-guide/dsl-api.html | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index c79f31ff63862..d727e699c3c8a 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -1834,6 +1834,11 @@

    The join will be triggered under the conditions listed below whenever new input is received. When it is triggered, the user-supplied ValueJoiner will be called to produce join output records.

    +
    +
      +
    • Input records with a null key or a null value are ignored and do not trigger the join.
      • +
    +

    • See the semantics overview at the bottom of this section for a detailed description.

    From a727ef555c1a6591e521d2180a3040dcd3193b9e Mon Sep 17 00:00:00 2001 From: Florin Akermann Date: Tue, 9 Apr 2024 20:48:16 +0200 Subject: [PATCH 4/5] KAFKA-12317: Fix documentation for KStream,KStream left join. --- docs/streams/developer-guide/dsl-api.html | 5 ----- 1 file changed, 5 deletions(-) diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index d727e699c3c8a..3d6584bf239ac 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -1891,11 +1891,6 @@

    The join will be triggered under the conditions listed below whenever new input is received. When it is triggered, the user-supplied ValueJoiner will be called to produce join output records.

    -
    -
      -
    • Input records with a null value are ignored and do not trigger the join.
      • -
    -

  • For each input record on the left side that does not have any match on the right side, the ValueJoiner will be called with ValueJoiner#apply(leftRecord.value, null); this explains the row with timestamp=60 and timestampe=80 in the table below, which lists [E, null] and [F, null]in the LEFT JOIN column. From 6f8d61a5f0c86cf2d207c9a138a5fc19022382bc Mon Sep 17 00:00:00 2001 From: Florin Akermann Date: Sat, 4 May 2024 09:53:03 +0200 Subject: [PATCH 5/5] Fix documentation for behavior of KTableKTable-Left-Join when ForeignKeyExtractor returns null. --- docs/streams/developer-guide/dsl-api.html | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index 3d6584bf239ac..fd5c22cae33bb 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -1891,6 +1891,11 @@

    The join will be triggered under the conditions listed below whenever new input is received. When it is triggered, the user-supplied ValueJoiner will be called to produce join output records.

    +
    +
      +
    • Input records with a null value are ignored and do not trigger the join.
      • +
    +

  • For each input record on the left side that does not have any match on the right side, the ValueJoiner will be called with ValueJoiner#apply(leftRecord.value, null); this explains the row with timestamp=60 and timestampe=80 in the table below, which lists [E, null] and [F, null]in the LEFT JOIN column. @@ -1947,6 +1952,11 @@

    The join will be triggered under the conditions listed below whenever new input is received. When it is triggered, the user-supplied ValueJoiner will be called to produce join output records.

    +
    +
      +
    • Input records with a null value are ignored and do not trigger the join.
      • +
    +

  • For each input record on one side that does not have any match on the other side, the ValueJoiner will be called with ValueJoiner#apply(leftRecord.value, null) or ValueJoiner#apply(null, rightRecord.value), respectively; this explains the row with timestamp=60, timestamp=80, and timestamp=100 in the table below, which lists [E, null], @@ -2532,6 +2542,10 @@

    KTable-KTable Foreign-Key