@Override
        public void run() {
            StringBuilder sBuilder = new StringBuilder(256);
            long startTime = System.currentTimeMillis();
            Set<String> expiredTopic = getExpiredTopicSet(sBuilder);
            if (!expiredTopic.isEmpty()) {
                logger.info(sBuilder.append("Found ").append(expiredTopic.size())
                        .append(" files expired, start delete files!").toString());
                sBuilder.delete(0, sBuilder.length());
                for (String topicName : expiredTopic) {
                    if (topicName == null) {
                        continue;
                    }
                    Map<Integer, MessageStore> storeMap = dataStores.get(topicName);
                    if (storeMap == null || storeMap.isEmpty()) {
                        continue;
                    }
                    for (Map.Entry<Integer, MessageStore> entry : storeMap.entrySet()) {
                        if (entry.getValue() == null) {
                            continue;
                        }
                        try {
                            entry.getValue().runClearupPolicy(false);
                        } catch (final Throwable e) {
                            logger.error(sBuilder.append("Try to run delete policy with ")
                                    .append(entry.getValue().getStoreKey())
                                    .append("'s log file  failed").toString(), e);
                            sBuilder.delete(0, sBuilder.length());
                        }
                    }
                }
                logger.info("Log Clear Scheduler finished file delete!");
            }
            long dltTime = System.currentTimeMillis() - startTime;
            if (dltTime >= tubeConfig.getLogClearupDurationMs()) {
                logger.warn(sBuilder.append("Log Clear up task continue over the clearup duration, ")
                        .append("used ").append(dltTime).append(", configure value is ")
                        .append(tubeConfig.getLogClearupDurationMs()).toString());
                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