Victor van den Hoven created KAFKA-14400: --------------------------------------------
Summary: 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.3.1, 3.1.1 Environment: Windows PC Reporter: Victor van den Hoven Attachments: 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. When using deprecated +JoinWindows.of(Duration.ofMillis(10000));+ the KStream {*}leftJoin{*}(KStream otherStream, ValueJoiner {_}joiner{_}, JoinWindows windows) does all the _joiner_ with null value when join predicate is not satisfied. Attached you can find two files with TopologyTestDriver Unit test to reproduce. -- This message was sent by Atlassian Jira (v8.20.10#820010)