[
https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13524:
---------------------------------
Summary: IQv2: Add option for KeyQuery from caches (was: IQv2: Add option
to query KV Stores from caches)
> IQv2: Add option for KeyQuery from caches
> -----------------------------------------
>
> Key: KAFKA-13524
> URL: https://issues.apache.org/jira/browse/KAFKA-13524
> Project: Kafka
> Issue Type: Sub-task
> Reporter: John Roesler
> Priority: Major
>
> I did a quick POC of this:
> [https://github.com/vvcephei/kafka/pull/new/iqv2-poc-cache-queries]
>
> The internal code of the caching stores should be refactored to share logic
> with the regular store methods. Scan queries will be more complicated, since
> they require merging the cache with the wrapped result.
> There is a bug related to that non-timestamped-store-serde hack (see the
> failing test when you run IQv2StoreIntegrationTest). Even though the inner
> store is not timestamped, the cache returns a timestamped value. We'll have
> to discuss options to fix it.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)