private  TopicPartition getStorePartition(final String storeName) {
        // NOTE we assume the partition of the topic can always be inferred from the task id;
        // if user ever use a custom partition grouper (deprecated in KIP-528) this would break and
        // it is not a regression (it would always break anyways)
        return new TopicPartition(changelogFor(storeName), taskId.partition());
    }
Alternative to {@link #close()} that just resets the changelogs without closing any of the underlying state
or unregistering the stores themselves
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java