public void addPartitionsForOffsetReset(final Set<TopicPartition> partitionsForOffsetReset) {
        mainConsumer.pause(partitionsForOffsetReset);
        resetOffsetsForPartitions.addAll(partitionsForOffsetReset);
    }
@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 TimeoutException if initializing record collector timed out
@throws StreamsException fatal error, should close the thread
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java