[
https://issues.apache.org/jira/browse/KAFKA-20776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18110285#comment-18110285
]
Naveen commented on KAFKA-20776:
--------------------------------
Hi Jess,
I'd like to pick this up, if you aren't already working on it.
> MeteredKeyValueStore / MeteredTimestampedKeyValueStore ignore skipCache() for
> KeyQuery and TimestampedKeyQuery
> --------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-20776
> URL: https://issues.apache.org/jira/browse/KAFKA-20776
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Jess Jin
> Assignee: Jess Jin
> Priority: Major
>
> When an IQv2 KeyQuery (or TimestampedKeyQuery) is issued with skipCache()
> against a metered key-value store, the metered store rebuilds the raw
> KeyQuery<Bytes, byte[]> it forwards to the wrapped (caching) store without
> propagating isSkipCache(). The caching layer therefore never sees skipCache.
> Affected handlers:
> - MeteredKeyValueStore.runKeyQuery
> - MeteredTimestampedKeyValueStore.runKeyQuery / runTimestampedKeyQuery
> - MeteredTimestampedKeyValueStoreWithHeaders.runKeyQuery /
> runTimestampedKeyQuery
> Fix:
> - Propagate isSkipCache() onto the raw KeyQuery forwarded by each of these
> handlers.
> - Collapse the repeated if (isSkipCache()) rawKeyQuery =
> rawKeyQuery.skipCache() into a single shared helper.
> - Add a shared test utility asserting skipCache propagation, and cover
> KeyQuery / TimestampedKeyQuery on the plain metered stores.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
