[jira] [Updated] (KAFKA-10847) Avoid spurious left/outer join results in stream-stream join

["Matthias J. Sax (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matthias J. Sax updated KAFKA-10847:
------------------------------------
    Fix Version/s:     (was: 3.0.0)
                   3.1.0

> Avoid spurious left/outer join results in stream-stream join 
> -------------------------------------------------------------
>
>                 Key: KAFKA-10847
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10847
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Matthias J. Sax
>            Assignee: Sergio Peña
>            Priority: Major
>             Fix For: 3.1.0
>
>
> KafkaStreams follows an eager execution model, ie, it never buffers input records but processes them right away. For left/outer stream-stream join, this implies that left/outer join result might be emitted before the window end (or window close) time is reached. Thus, a record what will be an inner-join result, might produce a eager (and spurious) left/outer join result.
> We should change the implementation of the join, to not emit eager left/outer join result, but instead delay the emission of such result after the window grace period passed.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)