[
https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Navinder Brar updated KAFKA-9445:
---------------------------------
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.
> Allow fetching a key from a single partition rather than iterating over all
> the stores on an instance
> -----------------------------------------------------------------------------------------------------
>
> Key: KAFKA-9445
> URL: https://issues.apache.org/jira/browse/KAFKA-9445
> Project: Kafka
> Issue Type: New Feature
> Components: streams
> Reporter: Navinder Brar
> Assignee: Navinder Brar
> Priority: Major
>
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
