private static void initializeAssignmentsForAllClients(final ApplicationState applicationState,
                                                           final Map<ProcessId, KafkaStreamsAssignment> assignments) {
        for (final ProcessId processId : applicationState.kafkaStreamsStates(false).keySet()) {
            if (!assignments.containsKey(processId)) {
                assignments.put(processId, KafkaStreamsAssignment.of(processId, new HashSet<>()));
            }
        }
    }
This function returns whether the current application state has the required rack information
to make assignment decisions with.

@param taskType the type of task that we are trying to validate rack information for.

@return whether rack-aware assignment decisions can be made for this application.
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java