void recordTaskProcessRatio(final long totalProcessLatencyMs, final long now) {
        for (final Task task : activeRunningTaskIterable()) {
            task.recordProcessTimeRatioAndBufferSize(totalProcessLatencyMs, now);
        }
    }
@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