@SuppressWarnings("unchecked")
    @Override
    public boolean setFlushListener(final CacheFlushListener<K, V> listener,
                                    final boolean sendOldValues) {
        if (wrapped instanceof CachedStateStore) {
            return ((CachedStateStore<K, V>) wrapped).setFlushListener(listener, sendOldValues);
        }
        return false;
    }
A storage engine wrapper for utilities like logging, caching, and metering.
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java