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
| Author | Alieh Saeedi |
| Status | Accepted |
| Kafka Version | 3.7 |
| JIRA | KAFKA-15346 |
| Wiki | View on Apache Wiki |
| Created | 2023-07-26 |
| Last Modified | 2023-10-24 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.