public boolean updateConfigMap(InLongMetaConfig metaConfig) {
        String inDataJsonStr;
        // check cache data
        synchronized (this.lastSyncVersion) {
            if (this.lastSyncVersion.get() > this.lastUpdVersion.get()) {
                if (tmpDataMd5.equals(metaConfig.getMd5())) {
                    return false;
                }
                LOG.info("Update metadata: NOT UPDATE, {} is loading, but wast over {} ms",
                        getFileName(), System.currentTimeMillis() - this.lastSyncVersion.get());
                return false;
            } else {
                if (dataMd5.equals(metaConfig.getMd5())) {
                    return false;
                }
            }
            InLongMetaConfig newMetaConfig = buildMixedMetaConfig(metaConfig);
            try {
                inDataJsonStr = GSON.toJson(newMetaConfig);
            } catch (Throwable e) {
                LOG.error("Update metadata: failure to serial meta config to json", e);
                return false;
            }
            return storeConfigToFile(inDataJsonStr, newMetaConfig);
        }
    }
get topic by groupId and streamId
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/MetaConfigHolder.java