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)
