default Map<TopicPartition, Long> purgeableOffsets() {
        return Collections.emptyMap();
    }
@throws StreamsException fatal error, should close the thread
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java