private boolean nodeGroupContainsGlobalSourceNode(final Set<String> allNodesOfGroups) {
        for (final String node : allNodesOfGroups) {
            if (isGlobalSource(node)) {
                return true;
            }
        }
        return false;
    }
@return names of all source topics, including the application id/named topology prefix for repartition sources
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java