You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Victoria Xia (Jira)" <ji...@apache.org> on 2023/03/22 17:24:00 UTC
[jira] [Created] (KAFKA-14834) Improved stream-table and table-table join semantics for versioned stores
Victoria Xia created KAFKA-14834:
------------------------------------
Summary: Improved stream-table and table-table join 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
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+Join+Processor+Semantics+for+Versioned+Stores], we will make the following two improvements:
* stream-table joins will perform a timestamped lookup (using the stream-side record timestamp) if the table is materialized with a versioned store
* table-table joins, including foreign key joins, will not produce new join results on out-of-order records (by key) from tables materialized with versioned stores
--
This message was sent by Atlassian Jira
(v8.20.10#820010)