yuluo-yx opened a new pull request, #4150: URL: https://github.com/apache/rocketmq-dashboard/pull/4150
文件与 RocksDB ConsumeQueue 双写迁移期间需要检查索引写入进度。新增单节点、单 Topic 的原生检查入口，整合存储配置审阅、时间范围选择、管理员确认、异步回执和日志定位。 GET 只读已登记节点的双写配置与 Topic；POST 重新校验节点、配置及 Topic，调用 checkRocksdbCqWriteProgress。只允许双写开启且两种存储均配置的节点；检查时间保持毫秒字符串，拒绝未来时间与溢出。操作经过管理员权限与安全审计，通信中断保留 UNKNOWN，不自动重试。 官方接口立即返回状态 2，最终结果只写 Broker 日志，没有任务 ID、轮询或取消接口。UI 的 ACCEPTED 仅表示受理，其它原始状态原样保留，不把“无需检查”误报为索引一致。提交消耗预览，修改检查条件清除确认，实例切换中止等待并丢弃迟到响应。中文文档解释时间查找回退、扫描负载、非原子采样与日志关联限制。 协议依据：[AdminBrokerProcessor](https://github.com/apache/rocketmq/blob/rocketmq-all-5.5.0/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java#L482) 的异步工作线程与 [CombineConsumeQueueStore](https://github.com/apache/rocketmq/blob/rocketmq-all-5.5.0/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java#L456) 的逐条比较行为。 本地后端 64、前端 23 项测试通过；服务行覆盖率 67/67、分支 56/62。Checkstyle、TypeScript/Vite 构建、后端打包通过，ESLint 0 错误、10 条现有告警。浏览器同一脚本校验 localhost 并精确拦截 GET/POST，验证单 Topic、时间参数、已审阅配置和 ACCEPTED 回执，未启动真实 Broker 扫描。 去重：全量 Issue/PR 标题正文及最新在线 checkRocksdbCqWriteProgress、RocksDB progress/consistency/check、双写进度/校验检索无同类功能。与队列清理不同，本项只启动索引比较，不调用删除或配置更新接口。 无新增依赖或数据库迁移；撤销代码提交可移除入口，无法取消已受理的原生任务。真实双写差异、日志关联、插件、性能、容量和故障注入未验证。既有全量测试与依赖审计缺口继续披露，按用户授权逐项增量验证提交，不宣称全量门槛通过。提交含 [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]
