

特性 | 4.x 集群 | 5.x 集群 |
重试队列粒度 | 以 Group 为单位 一个 Group 只有一个重试队列,它订阅的所有 Topic 的失败消息都发到这里。 | 以 Group&Topic 为粒度 一个 Group 针对它订阅的每个 Topic,都会有一个独立的专属重试队列。 |
重置普通队列的影响 | 重置某个 Topic 的消费位点时,不会自动重置重试队列。 | 重置某个 Topic 的消费位点时,会自动重置与之对应的那个专属重试队列的位点。 |
为何这样设计? | 为了避免“交叉影响”。 如果一个 Group 订阅了 Topic A 和 Topic B,当重置 Topic A 的位点时,如果也重置了共用的重试队列,那么 Topic B 的失败消息也会被影响。 | 因为天然隔离。 每个 Topic 都有自己独立的“重试队列”,重置 Topic A 时,只会动 Topic A 自己的重试队列,不会影响 Topic B 的重试队列,所以可以安全地自动完成。 |
额外功能 | 提供了一个独立的 “重置重试队列位点” 功能。如果需要清除所有失败消息,可以单独执行这个操作。 | 无需额外功能,因为重置 Topic 时已自动处理。 |

文档反馈