private Set<String> getExpiredTopicSet(final StringBuilder sb) {
            Set<String> expiredTopic = new HashSet<>();
            for (Map<Integer, MessageStore> storeMap : dataStores.values()) {
                if (storeMap == null || storeMap.isEmpty()) {
                    continue;
                }
                for (MessageStore msgStore : storeMap.values()) {
                    if (msgStore == null) {
                        continue;
                    }
                    try {
                        if (msgStore.runClearupPolicy(true)) {
                            expiredTopic.add(msgStore.getTopic());
                        }
                    } catch (final Throwable e) {
                        logger.error(sb.append("Try to run delete policy with ")
                                .append(msgStore.getStoreKey())
                                .append("'s log file failed").toString(), e);
                        sb.delete(0, sb.length());
                    }
                }
            }
            return expiredTopic;
        }
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