[jira] [Resolved] (KAFKA-14834) Improved processor semantics for versioned stores

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

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

Matthias J. Sax resolved KAFKA-14834.
-------------------------------------
    Fix Version/s: 3.5.0
       Resolution: Fixed

> Improved processor semantics for versioned stores
> -------------------------------------------------
>
>                 Key: KAFKA-14834
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14834
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Victoria Xia
>            Assignee: Victoria Xia
>            Priority: Major
>              Labels: kip, streams
>             Fix For: 3.5.0
>
>
> With the introduction of versioned state stores in [KIP-889|https://cwiki.apache.org/confluence/display/KAFKA/KIP-889%3A+Versioned+State+Stores], we should leverage them to provide improved join semantics. 
> As described in [KIP-914|https://cwiki.apache.org/confluence/display/KAFKA/KIP-914%3A+DSL+Processor+Semantics+for+Versioned+Stores], we will make the following four improvements:
>  * stream-table joins will perform a timestamped lookup (using the stream-side record timestamp) if the table is versioned
>  * table-table joins, including foreign key joins, will not produce new join results on out-of-order records (by key) from versioned tables
>  * table filters will disable the existing optimization to not send duplicate tombstones when applied to a versioned table
>  * table aggregations will ignore out-of-order records when aggregating a versioned table



--
This message was sent by Atlassian Jira
(v8.20.10#820010)