public void resumeTopics(Collection<String> topics) {
        for (Group group : groups) {
            for (Topic topic : group.consumers.keySet()) {
                if (topics.contains(topic.name)) {
                    List<Consumer> topicConsumers = group.consumers.get(topic);
                    if (topicConsumers != null) {
                        topicConsumers.forEach(Consumer::resume);
                    }
                }
            }
        }
    }
Resume all consumers for the specified topics across all groups.
tools/src/main/java/org/apache/kafka/tools/automq/perf/ConsumerService.java