public void maybeThrowTaskExceptionsFromProcessingThreads() {
        if (schedulingTaskManager != null) {
            maybeThrowTaskExceptions(schedulingTaskManager.drainUncaughtExceptions());
        }
    }
Take records and add them to each respective task

@param records Records, can be null
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java