conduktor.io ↗

KIP-806 — Add session and window query over kv-store in IQv2

Accepted Kafka 3.2 Streams

Adds `WindowKeyQuery` and `WindowRangeQuery` implementations of the `Query` interface from KIP-796 (Interactive Queries v2) for querying window and session stores by key and time range. IQv2 launched without session/window query support, meaning Streams applications using window/session stores could not use the new unified IQ API.

Details

AuthorPatrick Stuedi
StatusAccepted
Kafka Version3.2
JIRAKAFKA-13494
WikiView on Apache Wiki
Created2021-12-01
Last Modified2022-01-03
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.