[
https://issues.apache.org/jira/browse/KAFKA-14400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17636509#comment-17636509
]
Victor van den Hoven edited comment on KAFKA-14400 at 11/21/22 8:07 AM:
------------------------------------------------------------------------
I agree, but actually it is also happening with the ofTimeDifferenceAndGrace()
method.
As far as I can tell it has nothing to do with the grace period.
It just is not working correctly. Also Join() does seem to work, leftJoin()
isn't.
Maybe you can reproduce with the unit-test that I provided?.
was (Author: victorvandenhoven):
I agree, but actually it is also happening with the ofTimeDifferenceAndGrace()
method.
As far as I can tell it has nothing to do with the grace period.
It just is not working correctly. Also Join() does seem to work, leftJoin()
isn't.
Maybe you can reproduce with.
> KStream - KStream - LeftJoin() does not call ValueJoiner with null value
> -------------------------------------------------------------------------
>
> Key: KAFKA-14400
> URL: https://issues.apache.org/jira/browse/KAFKA-14400
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 3.1.1, 3.3.1
> Environment: Windows PC
> Reporter: Victor van den Hoven
> Priority: Major
> Attachments: Afbeelding 2.png, SimpleStreamTopology.java,
> SimpleStreamTopologyTest.java
>
>
> In Kafka-streams 3.1.1 :
> When using +JoinWindows.ofTimeDifferenceWithNoGrace(Duration.ofMillis(10000))+
> the KStream {*}leftJoin{*}(KStream otherStream, ValueJoiner {_}joiner{_},
> JoinWindows windows) does not seem to call the _joiner_ with null value when
> join predicate is not satisfied (not expected).
>
> When using deprecated +JoinWindows.of(Duration.ofMillis(10000));+
> the KStream {*}leftJoin{*}(KStream otherStream, ValueJoiner {_}joiner{_},
> JoinWindows windows) does
> call the _joiner_ with null value when join predicate is not satisfied (as
> expected and documented).
>
> Attached you can find two files with TopologyTestDriver Unit test to
> reproduce.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
