You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Victor van den Hoven (Jira)" <ji...@apache.org> on 2022/11/18 12:43:00 UTC

[jira] [Created] (KAFKA-14400) KStream - KStream - LeftJoin() does not call ValueJoiner with null value

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)