conduktor.io ↗

KIP-261 — Add Single Value Fetch in Window Stores

Accepted Kafka 1.1 Streams

Adds a `fetch(K key, long time)` single-point lookup to the `WindowStore` interface that retrieves the value for an exact window start time, in addition to the existing range query APIs. Without this, fetching the value for a known window required a `fetch(key, from, to)` range query even when the exact window start timestamp is known, unnecessarily scanning multiple windows.

Details

AuthorGuozhang Wang
StatusAccepted
Kafka Version1.1
JIRAKAFKA-6560
WikiView on Apache Wiki
Created2018-02-22
Last Modified2019-01-19
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.