yuluo-yx opened a new pull request, #4440: URL: https://github.com/apache/rocketmq-dashboard/pull/4440
<!-- Make sure the base branch is `master`: that is the RocketMQ Studio trunk. --> ### Which Issue(s) This PR Fixes - Fixes #4439 - Replaces #4125, closed by the branch switch in #4379. ### Brief Description This is a resubmission of #4125 against `master`, following the branch switch notice in #4379. The fork branch is unchanged; `master` is now the RocketMQ Studio trunk. 消费组的队列进度目前只有 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 或完成百分比。 ### How Did You Test This Change? ## 原提交验证记录 验证：本地后端 65 项、前端 41 项测试通过。新增服务 50/50 行、62/62 分支覆盖；Checkstyle、TypeScript/Vite 构建和后端打包通过，ESLint 0 错误、10 条现有告警。浏览器以本地 GET 拦截验证真实入口、超大整数、正常时间标记与回退区别，并确认底部按钮可见；没有访问真实 Broker。 ## 兼容性与回滚 无新增依赖，无数据迁移；撤销本提交即可回滚。三次读取不是原子快照，SDK 可能从副本读取且没有逐行来源地址；真实集群 E2E、压力、容量与混沌验证未执行。上游已有 3 项全量测试失败及既有依赖审计缺口（包含已由 #4000 处理的 Browserslist high），不宣称全量门槛通过，按用户已授权的增量验证方式交付。提交含 [skip ci]，未运行远端工作流。核验日期：2026-09-08。 ### Checklist - [x] One coherent change; unrelated modifications are not bundled in - [x] Commit subject follows Conventional Commits (`feat:` / `fix:` / `refactor:` / `chore:` / `docs:` / `perf:`) - [x] Tests added or updated for non-trivial changes, test methods named `...Test` - [x] New UI text has both Chinese and English entries under `web/src/i18n/`, or the change does not add UI text - [x] Architecture constraints stay green (`mvn test` runs the ArchUnit checks), or the original verification scope is stated above - [x] New source files carry the ASF license header, or no new source files were added - [x] Documentation touched where behaviour changed (README / `docs/` / in-app help), or no documentation change was required -- 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]
