conduktor.io ↗

KIP-889 — Versioned State Stores

Accepted Kafka 3.5 Streams

KIP-889 introduces versioned (multi-version) state stores in Kafka Streams that retain multiple timestamped values per key, enabling the store to answer point-in-time lookups. Existing state stores keep only the latest value per key, making stream-table joins produce incorrect results for out-of-order records because the correct historical table value is no longer available.

Details

AuthorVictoria Xia
StatusAccepted
Kafka Version3.5
JIRAKAFKA-14491
WikiView on Apache Wiki
Created2022-11-16
Last Modified2023-03-17
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.