public void refreshMessageStoresHoldVals(Map<String, TopicMetadata> oldTopicConfigMap,
            Map<String, TopicMetadata> newTopicConfigMap) {
        if (((newTopicConfigMap == null) || newTopicConfigMap.isEmpty())
                || ((oldTopicConfigMap == null) || oldTopicConfigMap.isEmpty())) {
            return;
        }
        StringBuilder sBuilder = new StringBuilder(512);
        for (TopicMetadata newTopicMetadata : newTopicConfigMap.values()) {
            TopicMetadata oldTopicMetadata = oldTopicConfigMap.get(newTopicMetadata.getTopic());
            if ((oldTopicMetadata == null) || oldTopicMetadata.isPropertyEquals(newTopicMetadata)) {
                continue;
            }
            ConcurrentHashMap<Integer, MessageStore> messageStores =
                    MessageStoreManager.this.dataStores.get(newTopicMetadata.getTopic());
            if ((messageStores == null) || messageStores.isEmpty()) {
                continue;
            }
            for (Map.Entry<Integer, MessageStore> entry : messageStores.entrySet()) {
                if (entry.getValue() != null) {
                    try {
                        entry.getValue().refreshUnflushThreshold(newTopicMetadata);
                    } catch (Throwable ee) {
                        logger.error(sBuilder.append("[Store Manager] refresh ")
                                .append(entry.getValue().getStoreKey())
                                .append("'s parameter error,").toString(), ee);
                        sBuilder.delete(0, sBuilder.length());
                    }
                }
            }
        }
    }
Refresh message-store's dynamic configures

@param oldTopicConfigMap     the stored topic configure map
@param newTopicConfigMap     the newly topic configure map
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java