yuluo-yx opened a new issue, #4451: URL: https://github.com/apache/rocketmq-dashboard/issues/4451
### Before Creating the Feature Request - [x] I have searched the [open issues](https://github.com/apache/rocketmq-dashboard/issues) and believe this is not a duplicate. - [x] I understand that a non-trivial feature is agreed in this issue first: the design is discussed here before a pull request is sent, as described in CONTRIBUTING.md. ### Is Your Feature Request Related to a Problem? 文件与 RocksDB ConsumeQueue 双写迁移期间需要检查索引写入进度。新增单节点、单 Topic 的原生检查入口，整合存储配置审阅、时间范围选择、管理员确认、异步回执和日志定位。 ### Describe the Solution You'd Like This issue records the design and implementation that was previously submitted in #4150 and closed automatically when `rocketmq-studio` was deleted during the branch switch announced in #4379. The pull request will be resubmitted against `master`, which now contains the same Studio history plus the new contribution templates. 文件与 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 扫描。 ## 兼容性与回滚 无新增依赖或数据库迁移；撤销代码提交可移除入口，无法取消已受理的原生任务。真实双写差异、日志关联、插件、性能、容量和故障注入未验证。既有全量测试与依赖审计缺口继续披露，按用户授权逐项增量验证提交，不宣称全量门槛通过。提交含 [skip ci]，未运行远端工作流。核验日期：2026-09-08。 ### Describe Alternatives You've Considered The alternatives, protocol limits, rollback notes and unverified areas are documented in the migrated pull request text above. The important migration point is that this keeps the same implementation branch and changes only the target base from `rocketmq-studio` to `master`. ### Additional Context - Replaces PR #4150: https://github.com/apache/rocketmq-dashboard/pull/4150 - Branch switch notice: #4379 - Target branch for the new PR: `master` ### Are You Willing to Implement It? - [x] Yes, I am willing to submit a pull request once the design is agreed. -- 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]
