@Override
    public Set<String> getGroupSubInfo(String group) {
        Set<String> result = new HashSet<>();
        Map<String, OffsetStorageInfo> topicPartOffsetMap = cfmOffsetMap.get(group);
        if (topicPartOffsetMap == null) {
            Set<String> groups = new HashSet<>(1);
            groups.add(group);
            Map<String, Set<String>> groupTopicInfo =
                    this.fileOffsetStorage.queryGroupTopicInfo(groups);
            result = groupTopicInfo.get(group);
        } else {
            for (OffsetStorageInfo storageInfo : topicPartOffsetMap.values()) {
                result.add(storageInfo.getTopic());
            }
        }
        return result;
    }
Get the topic set subscribed by the consume group

@param group    the queries group name
@return         the topic set subscribed
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/DefaultOffsetManager.java