default boolean needsInitializationOrRestoration() {
        return state() == State.CREATED || state() == State.RESTORING;
    }
@return any changelog partitions associated with this task
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java