@Override
        public void init(final ProcessorContext<K1, Change<V1>> context) {
            super.init(context);
            isNotUpgrade = isNotUpgrade(context().appConfigs());
        }
@throws IllegalStateException since this method should never be called
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java