void validateStoreOpen() {
        if (!wrapped.isOpen()) {
            throw new InvalidStateStoreException("Store " + wrapped.name() + " is currently closed.");
        }
    }
A storage engine wrapper for utilities like logging, caching, and metering.
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java