[jira] [Updated] (KAFKA-20875) Headers store adapters bypass the `WrappedStateStore` chain

["Ken Huang (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-20875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ken Huang updated KAFKA-20875:
------------------------------
    Fix Version/s: 4.3.2

> Headers store adapters bypass the `WrappedStateStore` chain
> -----------------------------------------------------------
>
>                 Key: KAFKA-20875
>                 URL: https://issues.apache.org/jira/browse/KAFKA-20875
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 4.4.0, 4.3.2
>            Reporter: Alan Lau
>            Assignee: Alan Lau
>            Priority: Blocker
>             Fix For: 4.3.2
>
>
> {{PlainToHeadersWindowStoreAdapter}} and {{TimestampedToHeadersWindowStoreAdapter}} wrap a store without participating in {{{}WrappedStateStore{}}}, making the wrapped store invisible to every chain.
> Both adapters hold their delegate in a private field and declare only {{{}implements WindowStore<Bytes, byte[]{}}}. {{{}WrappedStateStore{}}}'s helpers all terminate on a non-WrappedStateStore:
> {code:java}
> public static boolean isTimestamped(final StateStore stateStore) {
>     if (stateStore instanceof TimestampedBytesStore) return true;
>     else if (stateStore instanceof WrappedStateStore) return isTimestamped(wrapped());
>     else return false;
> }{code}
> So {{{}isTimestamped{}}}, {{{}isVersioned{}}}, {{isHeadersAware}} and {{findInner}} all return {{false/null}} for anything behind these adapters, as do the ~8 other call sites that walk the chain (`ProcessorStateManager:148`, `StateManagerUtil:87`, `StoreQueryUtils:442`, `TimestampedWindowStoreBuilder:107`, …).
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)