四、RocketMQ消息消费总览

1.消费者启动 2.消息消费总览 1.线程ReblanceService: 1.作用: a.Rebalanceservice线程每隔20s对消费者订阅的主题进行一次队列重新分配,每一次分配都会获取主题的所有队列、从 Broker 服务器实时查询当前该主题该消费组内消费者列表,对新分配的消息队列会创建对应的 PullRequest 对象。在一个 JVM 进程中,同一个消费组同一个队列只会存在一个 P
相关文章
相关标签/搜索