rocketmq springboot接入的测试

1.ConsumeFromWhere下关于设置消费者的消费进度

  • CONSUME_FROM_LAST_OFFSET:个新的订阅组第一次启动从队列的最后位置开始消费,后续再启动接着上次消费的进度开始消费,如果这个消费者组监听了一段时间后又不监听了,那么重新监听的话还是会重复消费了,其实最重要的还是防止消费者比如重启了,要重新的消费。
  • CONSUME_FROM_FIRST_OFFSET:一个新的订阅组第一次启动从队列的最前位置开始消费,后续再启动接着上次消费的进度开始消费。新加入的时候从0开始,跟上面的从最后不一样。但是两者后续都是一样的从上次消费完的位置继续的消费。
  • CONSUME_FROM_LAST不生效,导致的重复消费问题,请先问问自己是否属于以下两个情况:
    • 这个消费者组本来就监听这个Topic,你修改ConsumeFromWhere策略发布。对不起,这时候这个策略对于这个topic是不生效的
    • 这个消费者组本来就监听过这个Topic,但是由于后面服务发版的历史中,已经不监听了。但突然有一天,你发现又需要重新监听了,这时候ConsumeFromWhere也是不生效的。原因就是这个消费进度一直都被broker记住了
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容