rocketmq springboot接入的测试

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

• CONSUME_FROM_LAST_OFFSET:个新的订阅组第一次启动从队列的最后位置开始消费,后续再启动接着上次消费的进度开始消费,如果这个消费者组监听了一段时间后又不监听了，那么重新监听的话还是会重复消费了，其实最重要的还是防止消费者比如重启了，要重新的消费。
• CONSUME_FROM_FIRST_OFFSET：一个新的订阅组第一次启动从队列的最前位置开始消费，后续再启动接着上次消费的进度开始消费。新加入的时候从0开始，跟上面的从最后不一样。但是两者后续都是一样的从上次消费完的位置继续的消费。
• CONSUME_FROM_LAST不生效，导致的重复消费问题，请先问问自己是否属于以下两个情况：
  • 这个消费者组本来就监听这个Topic，你修改ConsumeFromWhere策略发布。对不起，这时候这个策略对于这个topic是不生效的
  • 这个消费者组本来就监听过这个Topic，但是由于后面服务发版的历史中，已经不监听了。但突然有一天，你发现又需要重新监听了，这时候ConsumeFromWhere也是不生效的。原因就是这个消费进度一直都被broker记住了