conduktor.io ↗

KIP-766 — fetch/findSessions queries with open endpoints for SessionStore/WindowStore

Discussion Kafka 3.1 Streams

Adds open-ended (unbounded) fetch/findSessions variants to `ReadOnlySessionStore` and `ReadOnlyWindowStore` in Kafka Streams, matching the open-ended range support added for `ReadOnlyKeyValueStore` in KIP-763. All existing session/window fetch APIs require explicit upper and lower time bounds, forcing workarounds with `Instant.MIN`/`MAX` when unbounded queries are needed.

Details

AuthorLuke Chen
StatusDiscussion
Kafka Version3.1
JIRAKAFKA-13210
WikiView on Apache Wiki
Created2021-08-03
Last Modified2021-08-20
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.