conduktor.io ↗

KIP-960 — Support single-key_single-timestamp Interactive Queries (IQv2) for Versioned State Stores

Accepted Kafka 3.7 Streams

KIP-960 adds a `VersionedKeyQuery<K, V>` class to Kafka Streams IQv2 supporting single-key lookups against versioned state stores (`VersionedKeyValueStore`) with an optional `asOf(Instant)` timestamp to retrieve the value valid at a specific point in time. Versioned state stores (introduced in KIP-889) expose time-varying key-value state but lacked an interactive query interface, making the stored temporal history inaccessible from outside the topology.

Details

AuthorAlieh Saeedi
StatusAccepted
Kafka Version3.7
JIRAKAFKA-15346
WikiView on Apache Wiki
Created2023-07-26
Last Modified2023-10-24
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.