[ https://issues.apache.org/jira/browse/KAFKA-14400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17636512#comment-17636512 ]
Victor van den Hoven edited comment on KAFKA-14400 at 11/21/22 8:06 AM: ------------------------------------------------------------------------ Also with the deprecated joinWindows (using ofTimeDifferenceAndGrace()) a different topology is being produced: In line 13 and line 16 you will find a new {*}KSTREAM-OUTERSHARED-0000000004-store{*}. Where is that coming from? !Afbeelding 2.png! was (Author: victorvandenhoven): Also with the deprecated joinWindows a diferent topology is being produced: In line 13 and line 16 you will find a new KSTREAM-OUTERSHARED-0000000004-store. Where is that coming from? !Afbeelding 2.png! > 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)