int punctuate() {
        return  taskExecutor.punctuate();
    }
@throws TaskMigratedException if the task producer got fenced (EOS only)
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java