Major Description
Whenever a call is made to get a particular key from a Kafka Streams instance, currently it returns a Queryable store that contains a list of the stores for all the running and restoring/replica(with KIP-535) on the instance via StreamThreadStateStoreProvider#stores(). This list of stores is then provided to CompositeReadOnlyKeyValueStore#get() which looks into each store one by one. With the changes that went in as a part of KIP-535 since we have access to the information that a key belongs to which partition, we should have a capability to fetch store for that particular partition and look for key in store for that partition only. It would be a good improvement for improving latencies for applications that contain multiple partitions on a single instance and don't have bloom filters enabled internally for Rocksdb.
Attachments
Issue Links
- relates to
-
KAFKA-9487 Followup : KAFKA-9445(Allow fetching a key from a single partition); addressing code review comments
-
- Resolved
-
- links to
1.
|
Add documentation change for KIP-562 |
|
Resolved | Boyang Chen |