conduktor.io ↗

KIP-614 — Add Prefix Scan support for State Stores

Accepted Kafka 2.8 Streams

Adds a `prefixScan(prefix, serializer)` method to `ReadOnlyKeyValueStore` and its RocksDB/in-memory implementations in Kafka Streams for efficiently retrieving all keys sharing a common byte prefix. Currently there is no native prefix query; developers must use `range()` with a manually computed upper bound or iterate the full key space, incurring unnecessary I/O.

Details

AuthorSagar Rao
StatusAccepted
Kafka Version2.8
JIRAKAFKA-10648
WikiView on Apache Wiki
Created2020-05-12
Last Modified2020-10-27
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.