@Override
        public void run() {
            StringBuilder sBuilder = new StringBuilder(256);
            for (Map<Integer, MessageStore> storeMap : dataStores.values()) {
                if (storeMap == null || storeMap.isEmpty()) {
                    continue;
                }
                for (MessageStore msgStore : storeMap.values()) {
                    if (msgStore == null) {
                        continue;
                    }
                    try {
                        msgStore.flushMemCacheData();
                    } catch (final Throwable e) {
                        logger.error(sBuilder.append("[Store Manager] Try to flush ")
                                .append(msgStore.getStoreKey())
                                .append("'s mem-store failed : ").toString(), e);
                        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