public synchronized void registerTaskError(final Task task, final Throwable t, final long now) {
            log.info("Begin backoff for unhealthy task {} at t={} due to {}", task.id(), now, t.getClass().getName());
            tasksToErrorTime.put(task.id(), now);
        }
Multi-threaded class that tracks the status of active tasks being processed. A single instance of this class is
shared between all StreamThreads.
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadata.java