conduktor.io ↗

KIP-992 — Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery

Discussion Kafka 3.7 Streams

Introduces TimestampedKeyQuery and TimestampedRangeQuery as explicit IQv2 query types for timestamped key-value stores, and fixes KeyQuery/RangeQuery to always return plain V from both kv-store and ts-kv-store. Previously, KeyQuery returned ValueAndTimestamp<V> against a ts-kv-store, creating type-safety issues and unintuitive API behavior.

Details

AuthorPengcheng Zheng
StatusDiscussion
Kafka Version3.7
JIRAKAFKA-15629
WikiView on Apache Wiki
Created2023-10-17
Last Modified2023-12-07
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.