yuluo-yx opened a new pull request, #4120:
URL: https://github.com/apache/rocketmq-dashboard/pull/4120

   消息队列浏览目前只能按 offset 拉取消息正文,无法检查 ConsumeQueue 的物理位置、扩展索引缺失或 SQL92 初筛信息。本 PR 
在队列行增加只读索引诊断入口,使用 RocketMQ 原生 queryConsumeQueue,并完整处理协议的边界和结果语义。
   
   - 复用所选 Apache 实例的凭据,主节点必须来自实例登记信息,并核对 Topic 队列和采样范围;不接受任意 Broker 地址。
   - 所有 64 位位置和 tagsCode 使用字符串,保留超过 2^53 的值。count 限制为 1–32,等于队列末尾时返回明确的 
atEnd,缺失响应不伪装为空结果。
   - 索引条目只有序号,不推算 SDK 未返回的逻辑 queueOffset。仅在确实执行扩展过滤时展示布尔初筛结果,其余显示 Not 
evaluated;Passed 不代表最终消息匹配。
   - 页面提供原始扩展 JSON、位图和 Broker 提示,修改参数清除旧结果,关闭与切换实例丢弃迟到响应。云实例、模拟模式不开放入口。
   
   验证:本地后端 69 项、前端 49 项测试通过;新增服务 56/56 行、66/66 
分支覆盖;Checkstyle、ESLint、TypeScript/Vite 
构建及后端打包通过。浏览器使用本地拦截验证队列入口、超大偏移、初筛三态中的未执行/通过,以及扩展缺失提示,没有真实 Broker 调用。HTTP 
契约使用真实服务和实例解析器,模拟底层 SDK。
   
   
协议依据:[AdminBrokerProcessor.queryConsumeQueue](https://github.com/apache/rocketmq/blob/rocketmq-all-5.5.0/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java#L2783)。Broker
 默认 eval=false 并不等于执行过滤后失败;返回的 ConsumeQueueData 不含逻辑索引。该功能不同于消息拉取过滤预览,也不修改消费位点。
   
   去重:核对当前快照的全部 Issue/PR 标题正文中的 queryConsumeQueue、ConsumeQueueData、索引诊断,并在线检索开放 
PR 的 consume queue index,未找到相同功能。按领域合并 API、界面、契约和操作文档,避免拆分碎 PR。
   
   无新增依赖、无数据迁移;撤销本提交即可回滚。Topic 范围与索引读取不是原子快照,真实 Broker 版本兼容性、集群 
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]

Reply via email to