default void addPartitionsForOffsetReset(final Set<TopicPartition> partitionsForOffsetReset) {
        throw new UnsupportedOperationException();
    }
@throws TaskCorruptedException if the state cannot be reused (with EOS) and needs to be reset
@throws LockException    could happen when multi-threads within the single instance, could retry
@throws StreamsException fatal error, should close the thread
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java