public void updCsmTopicMetaInfo(Map<String, String> newMetaInfoMap) {
        lastMetaInfoFreshTime.set(System.currentTimeMillis());
        if (newMetaInfoMap == null || newMetaInfoMap.isEmpty()) {
            return;
        }
        String newConfig;
        String curConfig;
        boolean isChanged = false;
        Set<String> newTopics = newMetaInfoMap.keySet();
        Set<String> curTopics = topicMetaInfoMap.keySet();
        if (newTopics.size() != curTopics.size()
                || !newTopics.containsAll(curTopics)) {
            isChanged = true;
        } else {
            for (String topicKey : newTopics) {
                newConfig = newMetaInfoMap.get(topicKey);
                curConfig = topicMetaInfoMap.get(topicKey);
                if (newConfig == null) {
                    continue;
                }
                if (!newConfig.equals(curConfig)) {
                    isChanged = true;
                    break;
                }
            }
        }
        if (isChanged) {
            for (String newTopic : newTopics) {
                topicMetaInfoMap.put(newTopic, newMetaInfoMap.get(newTopic));
            }
            topicMetaInfoId.set(System.currentTimeMillis());
        }
    }
Update topic meta information

@param newMetaInfoMap  the newly acquired topic metadata
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodeconsumer/ConsumeGroupInfo.java