消息队列RocketMQ版ConsumeTimeout的含义是什么？

含义：最长的消费时间，如果超过了这个时间就认为消息消费失败了；主要目的 是为了能尽早的将 offset 确认，避免消息重复，例如对于并发消息有 100 条 0~99 ， 第 0 条长时间消费没成功，后面的 99 条消费成功了，如果不将第 0 条失败掉，那么 offset 一直不能后移到 100，假如此时进行 rebalance 后面的 99 条就有可能进行重 新消费。 设置方式：默认 15 分钟。 作用域：无序集群消费。 原理：对于并发消费 ConsumerMessageConcurrentlyService 启动一个线程 按照固定的周期清理 queue 消费时长超过的消息，并发回 broker，这样 offset 就可 以前移了。 注意： 1. 由于 ConsumeTimeout 在 broker 启动时，启东应用程序，所以之后修改 无效。 2. 由于定期时间是 consumeTimeout，并且每次判断消息开始消费到 现在是 否超时，这样有效期可能是两倍。