KIP-914 — DSL Processor Semantics for Versioned Stores
Accepted Kafka 3.5 Streams
Enables versioned key-value stores (KIP-889) to be used as backing stores for `KTable` in DSL stream-table joins, so out-of-order stream records are joined against the table value at the record's event timestamp rather than the latest value. Without versioned stores, stream-table joins always use the latest table value regardless of event time, producing incorrect results for late-arriving stream records.
Details
| Author | Victoria Xia |
| Status | Accepted |
| Kafka Version | 3.5 |
| JIRA | KAFKA-14834 |
| Wiki | View on Apache Wiki |
| Created | 2023-03-10 |
| Last Modified | 2023-04-13 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.