conduktor.io ↗

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

AuthorVictoria Xia
StatusAccepted
Kafka Version3.5
JIRAKAFKA-14834
WikiView on Apache Wiki
Created2023-03-10
Last Modified2023-04-13
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.