private void replaceCacheConfig(CacheType cacheType,
            Map<String, CacheClusterConfig> clusterConfigMap,
            Map<String, IdTopicConfig> idTopicConfigMap) {
        this.clusterType.getAndSet(cacheType.getId());
        // remove deleted id2topic config
        Set<String> tmpRmvKeys = new HashSet<>();
        for (Map.Entry<String, IdTopicConfig> entry : id2TopicSrcMap.entrySet()) {
            if (entry == null || entry.getKey() == null || entry.getValue() == null) {
                continue;
            }
            if (!idTopicConfigMap.containsKey(entry.getKey())) {
                tmpRmvKeys.add(entry.getKey());
            }
        }
        for (String key : tmpRmvKeys) {
            id2TopicSrcMap.remove(key);
        }
        // add new id2topic source config
        id2TopicSrcMap.putAll(idTopicConfigMap);
        // add new id2topic sink config
        id2TopicSinkMap.putAll(idTopicConfigMap);
        // remove deleted cluster config
        tmpRmvKeys.clear();
        for (Map.Entry<String, CacheClusterConfig> entry : mqClusterMap.entrySet()) {
            if (entry == null || entry.getKey() == null || entry.getValue() == null) {
                continue;
            }
            if (!clusterConfigMap.containsKey(entry.getKey())) {
                tmpRmvKeys.add(entry.getKey());
            }
        }
        for (String key : tmpRmvKeys) {
            mqClusterMap.remove(key);
        }
        // add new mq cluster config
        mqClusterMap.putAll(clusterConfigMap);
    }
update locally cached configuration with input information

@param cacheType  mq cluster type
@param clusterConfigMap  mq cluster config
@param idTopicConfigMap  id to topic config
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/MetaConfigHolder.java