@Override
        public void init(final ProcessorContext<Integer, Integer> context) {
            this.context = context;
            store = context.getStateStore(STORE_NAME);
        }
@param writeToStore whether or not this processor should write to the store
@param initialData  expected store contents which have already been inserted from
                    outside of this processor
streams/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java