Apache RocketMQ 从入门到实战中存在默认主题的路由配 置信息,则根据消息发送请求中的队列数量,在 Broker 创建新 Topic 的路由信息。这样 Broker 服务端就会存在主题的路由信息。 在 Broker 端的 topic 配置管理器中存在的路由信息,一会向 Nameserver 发送心跳 包,汇报到 Nameserver,另一方面会有一个定时任务,定时存储在 broker 端,具体路 径为${ROCKET_HOME}/store/config/topics 生产环境中,autoCreateTopicEnable 为什么不能设置为 true < 26 messageQueue:0),向 Broker 发送消息,Broker 服务器在处理消息时,首先会查看自 己的路由配置管理器(TopicConfigManager)中的路由信息,此时不存在对应的路由信息, 然后尝试查询是否存在默认 Topic 的路由信息,如果存在,说明启用了 autoCreateTopi cEnable,则在 时,才会从第一条消息开始消费,故接下来重点分析消息消费 进度存储器(OffsetStore)在什么情况下会返回 0。 接下来我们将以集群模式来查看一下消息消费进度的查询逻辑,集群模式的消息进度存 储管理器实现为:RemoteBrokerOffsetStore,最终 Broker 端的命令处理类为: ConsumerManageProcessor。 ConsumerManageProcessor#queryConsumerOffset0 码力 | 165 页 | 12.53 MB | 1 年前3
共 1 条
- 1













