conduktor.io ↗

KIP-617 — Allow Kafka Streams State Stores to be iterated backwards

Accepted Kafka 2.7 Streams

Adds `backwardRange()`, `backwardAll()`, and `backwardFetch()` methods to `ReadOnlyKeyValueStore`, `ReadOnlyWindowStore`, and `ReadOnlySessionStore` in Kafka Streams for reverse-order iteration. All existing store iteration APIs return results in ascending order; there is no way to iterate from newest to oldest or in reverse key order without materializing all results in memory.

Details

AuthorJorge Esteban Quilcate Otoya
StatusAccepted
Kafka Version2.7
JIRAKAFKA-9929
WikiView on Apache Wiki
Created2020-05-19
Last Modified2020-07-29
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.