集群模式偏移问题

我使用的RocketMQ版本是4.5.0,我询问的是消费者集群模式的进展情况:

1、 当消费者将偏移量同步到Broker时,它会随机选择一个Broker(Master或Slave); 代码: FindBrokerResult FindBrokerResult=this.mQClientFactory.findBrokerAddressInAdmin(mq.getBrokerName());(MQClientInstance#findBrokerAddressInAdmin);

2、 当消费者启动时,它会对Broker端执行动态重载,以拉取和取消消费点的偏移,这也是一个随机选择的Broker。因此,问题是:如何确保提取的偏移量是与Broker同步的最新消费者?如果提取的Broker偏移量为0,难道不需要每次都重新消耗吗?

原提问者GitHub用户xu-weize

展开
收起
芬奇福贵 2023-05-26 10:29:08 68 分享 版权
1 条回答
写回答
取消 提交回答
  • 最新的代码,在分支机构开发中,只向主代理提交偏移量。

    原回答者GitHub用户ni-ze

    2023-05-26 16:52:12
    赞同 展开评论

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

还有其他疑问?
咨询AI助理