conduktor.io ↗

KIP-562 — Allow fetching a key from a single partition rather than iterating over all the stores on an instance

Discussion Kafka 2.5 Streams

KIP-562 adds a `partition` parameter to `KafkaStreams.store()` so callers can query a specific partition of a local state store rather than always querying all local partitions. The existing API forces the store wrapper to iterate over all partitions on the instance, making it impossible for a query-routing layer (as designed in KIP-535) to execute a targeted sub-query against a single active or standby partition replica.

Details

AuthorNavinder Pal Singh Brar
StatusDiscussion
Kafka Version2.5
JIRAKAFKA-9445
WikiView on Apache Wiki
Created2020-01-17
Last Modified2020-02-06
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.