conduktor.io ↗

KIP-205 — Add all() and range() API to ReadOnlyWindowStore

Accepted Kafka 1.1 Streams

Adds all() and range(K from, K to, long fromTime, long toTime) APIs to ReadOnlyWindowStore in Kafka Streams, enabling full scans and key-range scans over windowed state stores. The existing ReadOnlyWindowStore only offered fetch-by-key methods, requiring callers to know keys in advance and making it impossible to iterate or scan the store without prior knowledge.

Details

AuthorRichard Yu
StatusAccepted
Kafka Version1.1
JIRAKAFKA-4499
WikiView on Apache Wiki
Created2017-09-25
Last Modified2017-11-17
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.