conduktor.io ↗

KIP-997 — update WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery

Discussion Streams

Extends `WindowRangeQuery` in the Kafka Streams Interactive Queries API to support dual-key range queries (`keyFrom`, `keyTo`, `timeFrom`, `timeTo`), unifying it with `WindowKeyQuery`. The existing `WindowRangeQuery.fetchAll(timeFrom, timeTo)` fetches all keys in a time window but cannot restrict the key range, forcing clients to post-filter.

Details

AuthorPengcheng Zheng
StatusDiscussion
JIRAKAFKA-15795
WikiView on Apache Wiki
Created2023-11-01
Last Modified2023-12-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.