RocketMQ存储Topic消息时会按照TopicQueue进行划分. 如下图
首先按照BrokerName划分到不同的master上(每一个master可以有自己的slave,但是slave的BrokerName和master是一样的). 划分到具体的master后又回分到不同的queue上, 每一个master维护自己的queue(即不同master之间的queue没有联系).
目前是这么理解的, 如果错误后续纠正.
RocketMQ存储Topic消息时会按照TopicQueue进行划分. 如下图
首先按照BrokerName划分到不同的master上(每一个master可以有自己的slave,但是slave的BrokerName和master是一样的). 划分到具体的master后又回分到不同的queue上, 每一个master维护自己的queue(即不同master之间的queue没有联系).
目前是这么理解的, 如果错误后续纠正.