@Override
    public Collection<MessageStore> getMessageStoresByTopic(final String topic) {
        final ConcurrentHashMap<Integer, MessageStore> map = this.dataStores.get(topic);
        if (map == null) {
            return Collections.emptyList();
        }
        return map.values();
    }
Get message store by topic.

@param topic  query topic name
@return       the queried topic's store list
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java