public void registerTaskError(final Task task, final Throwable t, final long now) {
        if (hasNamedTopologies) {
            final String topologyName = task.id().topologyName();
            topologyNameToErrorMetadata.computeIfAbsent(topologyName, n -> new NamedTopologyMetadata(topologyName))
                .registerTaskError(task, t, 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