You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "John Roesler (Jira)" <ji...@apache.org> on 2021/12/29 05:04:00 UTC

[jira] [Updated] (KAFKA-13524) IQv2: Add option for KeyQuery from the RecordCache

     [ 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 the RecordCache  (was: IQv2: Add option for KeyQuery from caches)

> IQv2: Add option for KeyQuery from the RecordCache
> --------------------------------------------------
>
>                 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)