@Override
    public void cleanRmvTopicInfo(Set<String> rmvTopics) {
        if (rmvTopics == null || rmvTopics.isEmpty()) {
            return;
        }
        int cycleCnt = 0;
        long curSyncTime;
        Set<String> rmvGroups;
        do {
            cycleCnt++;
            curSyncTime = this.sync2FileTime.get();
            rmvGroups = this.fileOffsetStorage.cleanRmvTopicInfo(rmvTopics);
            if (!rmvGroups.isEmpty()) {
                for (String group : rmvGroups) {
                    this.cfmOffsetMap.remove(group);
                    this.tmpOffsetMap.remove(group);
                    this.offlineGroupHisInfoMap.remove(group);
                }
                logger.info("[Offset Manager] clean removed topic storage info, topics={}, groups={}",
                        rmvTopics, rmvGroups);
            }
        } while (cycleCnt < 2 && curSyncTime != this.sync2FileTime.get());
    }
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