[
https://issues.apache.org/jira/browse/KAFKA-13524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13524:
---------------------------------
Description:
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.
> IQv2: Add option to query KV Stores 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)
