#12332·seatunnel

[错误][Connector-V2][RocketMQ] 临时主题路由间隙被读取为"没有已提交的组偏移量",默默地将 CONSUME_FROM_GROUP_OFFSETS 回滚到第一个偏移量

作者: SEPURI-SAI-KRISHNA创建于 2026年9月16日更新于 2026年9月18日

**什么发生** `RocketMqAdminUtil.currentOffsets` 将临时元数据查找失败视为消费者组未提交任何内容的证据。在 `start.mode = CONSUME_FROM_GROUP_OFFSETS` 时,这使得源默默地回滚到第一个偏移量并重新传递整个主题,尽管已提交的偏移量存在且完好无损。

内容来源: apache/seatunnel