public boolean canPunctuateTask(final Task task) {
        final String topologyName = task.id().topologyName();

        if (topologyName == null) {
            return !pausedTopologies.contains(UNNAMED_TOPOLOGY);
        } else {
            return !pausedTopologies.contains(topologyName);
        }
    }
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