@Override
        public void init(final ProcessorContext<Integer, Integer> context) {
            this.context = context;
            store = context.getStateStore(STORE_NAME);
        }
Same as {@link VersionedStoreContentCheckerProcessor} but for regular key-value stores instead,
for use in validating the manual upgrade path from non-versioned to versioned stores.
streams/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java