public TubeBroker getTubeBroker() {
        return this.tubeBroker;
    }
Get or create message store.

@param topic           the topic name
@param partition       the partition id
@return                the message-store instance
@throws IOException    the exception during processing
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java