Set<TaskId> activeRunningTaskIds() {
        return activeRunningTaskStream()
            .map(Task::id)
            .collect(Collectors.toSet());
    }
Closes and cleans up after the provided tasks, including closing their corresponding task producers
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java