@Override
    public Map<String, TopicPubInfo> getTopicPublishInfos() {
        TopicPubInfo topicPubInfo;
        Map<String, TopicPubInfo> result = new HashMap<>();
        for (Map.Entry<String, ConcurrentHashMap<Integer, MessageStore>> entry : dataStores.entrySet()) {
            if (entry == null
                    || entry.getKey() == null
                    || entry.getValue() == null
                    || entry.getValue().isEmpty()) {
                continue;
            }
            for (Map.Entry<Integer, MessageStore> entry1 : entry.getValue().entrySet()) {
                if (entry1 == null
                        || entry1.getKey() == null
                        || entry1.getValue() == null) {
                    continue;
                }
                topicPubInfo = result.get(entry.getKey());
                if (topicPubInfo == null) {
                    topicPubInfo = new TopicPubInfo(entry.getKey());
                    result.put(entry.getKey(), topicPubInfo);
                }
                topicPubInfo.addStorePubInfo(entry1.getKey(), entry1.getValue().getPartitionNum(),
                        entry1.getValue().getIndexMinOffset(), entry1.getValue().getIndexMaxOffset(),
                        entry1.getValue().getDataMinOffset(), entry1.getValue().getDataMaxOffset());
            }
        }
        return result;
    }
Query all topic's publish info.

@return the current topic's offset info
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java