yuluo-yx opened a new pull request, #4125: URL: https://github.com/apache/rocketmq-dashboard/pull/4125
消费组的队列进度目前只有 offset 与消息数，无法直接判断各队列保留消息的时间范围，或位点附近的消息是否已被保留策略清除。本 PR 增加按 Topic 读取各队列时间跨度的只读入口，与消费组进度表集成。 - 同一实例的 AdminClient 读取 Topic 范围、消费组位点和原生 queryConsumeTimeSpan，按 Broker/Queue 排序；缺失队列时间数据明确提示，拒绝重复条目或变化中的队列映射。 - 区分正常位点参考、最早消息回退、位点在保留范围外、位点缺失、时间戳缺失。offset=0 时 Broker 返回的最早消息时间不作为消费成功记录。 - 位点和毫秒时间戳以字符串保留精度，日期显示为 UTC。条带只展示有效保留时间区间，并只标注区间内的正常位点参考。 - 手动查询和刷新，关闭或实例切换取消浏览器请求并丢弃迟到响应。真实 Apache 实例开放，云实例及模拟模式不展示入口。附中文操作、数据语义及回滚文档。 协议依据：[AdminBrokerProcessor.queryConsumeTimeSpan](https://github.com/apache/rocketmq/blob/rocketmq-all-5.5.0/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java#L2272) 与 [DefaultMQAdminExtImpl](https://github.com/apache/rocketmq/blob/rocketmq-all-5.5.0/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java#L1135)。Broker 在缺少正消费位点时回退到 minTime；原始 delayTime 可能依赖缺失的消息时间戳，因此本功能不以此推导积压年龄、SLO 或完成百分比。 验证：本地后端 65 项、前端 41 项测试通过。新增服务 50/50 行、62/62 分支覆盖；Checkstyle、TypeScript/Vite 构建和后端打包通过，ESLint 0 错误、10 条现有告警。浏览器以本地 GET 拦截验证真实入口、超大整数、正常时间标记与回退区别，并确认底部按钮可见；没有访问真实 Broker。 去重：检索全部 Issue/PR 快照标题正文的 queryConsumeTimeSpan、消费时间范围、时间跨度、consume time span，并在线搜索同名功能，未找到重复。按同一功能合并接口、界面、协议测试及文档。 无新增依赖，无数据迁移；撤销本提交即可回滚。三次读取不是原子快照，SDK 可能从副本读取且没有逐行来源地址；真实集群 E2E、压力、容量与混沌验证未执行。上游已有 3 项全量测试失败及既有依赖审计缺口（包含已由 #4000 处理的 Browserslist high），不宣称全量门槛通过，按用户已授权的增量验证方式交付。提交含 [skip ci]，未运行远端工作流。核验日期：2026-09-08。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
