int process(final int maxNumRecords, final Time time) {
        return taskExecutor.process(maxNumRecords, time);
    }
@throws TaskMigratedException if the task producer got fenced (EOS only)
@throws StreamsException      if any task threw an exception while processing
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java