feat(mq): improve Kafka peek defaults and localize admin console by xddcode · Pull Request #3375 · t8y2/dbx

xddcode · 2026-07-14T02:20:13Z

变更说明

1. Kafka 消息查询默认更易用（对应 #3357）

目的：很多 topic 用户并不清楚 partition / offset，原先必须手填，填错就报错或查空，门槛过高。

处理：

Agent / Rust：未指定 partition 时按全部分区读取；未指定 offset 时从各分区 earliest 起读，结果排序后按条数上限截断
UI：Messages 高级筛选（分区 / Offset）默认收起；Monitoring 默认 SQL 改为 SELECT * FROM "topic" LIMIT 20，可不写 PARTITION / OFFSET
仍支持显式指定分区与 offset，做精确范围查询

2. MQ 管理台多语言

目的：MQ Admin / 连接表单此前大量硬编码中英文，切换语言后界面混杂，且 JSON 示例文案会触发 vue-i18n 编译崩溃（{"key":"value"} 被当成插值）。

处理：

管理台各面板与 MQ 连接配置改为 i18n key
补齐 en / zh-CN / zh-TW / ja / es / it / pt-BR
JSON 占位符按 vue-i18n 规则转义（{'{'} / {'}'}）
统一术语：界面普通名词本地化，Topic / Broker / Offset / ISR 等行业术语保留

变更类型

涉及前端

验证

make check 通过
make cargo-check-fast 通过
相关测试通过（KafkaAgentTest、MQ 前端相关单测）

关联 Issue

close #3357

Make Kafka message peek read all partitions from earliest when partition/offset are omitted, and wire MQ admin UI strings through i18n for all supported locales. Co-authored-by: Cursor <cursoragent@cursor.com>

Localize ordinary Italian UI nouns on the MQ admin surface while keeping Kafka/Pulsar domain loanwords such as Topic, Broker, Offset, and ISR. Co-authored-by: Cursor <cursoragent@cursor.com>

Localize ordinary Producer/Consumer and related labels, and clean leftover topic/Permits English in Chinese locales. Co-authored-by: Cursor <cursoragent@cursor.com>

t8y2 · 2026-07-14T02:28:31Z

最好在此PR中提供一下相关页面截图

xddcode · 2026-07-14T02:35:28Z

最好在此PR中提供一下相关页面截图

描述已经完善，麻烦审查

Send success returns numbers while the peek filter inputs are string refs for empty optional values. Co-authored-by: Cursor <cursoragent@cursor.com>

变更说明在设置 → 关于我们中内嵌各版本更新日志，方便用户直接查看历史更新内容，无需跳转官网或 GitHub。实现方式：复用现有 R2 changelog JSON（releases-cn/en.json），经后端 Tauri command / Web API（/api/changelog）拉取，避免浏览器直连 CDN 的 CORS 问题。列表默认收起，最新版本展示 NEW 角标，支持展开详情、分页加载，以及官网 / GitHub Release 外链兜底。变更类型 - [x] 新功能 - [ ] Bug 修复 - [ ] 性能优化 - [ ] 代码重构 - [ ] 文档更新 - [ ] CI / 构建涉及前端 - [x] 本 PR 涉及前端改动，已附截图/录屏（见下方）验证 - [ ] make check 通过 - [ ] make cargo-check-fast 通过 - [x] 相关功能本地验证通过补充覆盖：关于我们页加载中/英文 changelog、展开收起、NEW 角标、加载失败外链兜底、后端代理绕过 CORS。关联 Issue 无 Co-authored-by: Cursor <cursoragent@cursor.com>

feat(settings): embed version changelog in About page

Resolve changelog both-added conflict by keeping createLatestRequestGuard. Co-authored-by: Cursor <cursoragent@cursor.com>

onceMisery · 2026-07-14T13:03:53Z

LGTM

onceMisery · 2026-07-14T13:34:37Z

话说回来，监控页的样式能否优化一下，我不懂前端，这个是我随便找gpt给写的，能优化下样式吗 🐶

t8y2

request changes: Kafka 消息读取存在一个会导致误报空结果的回归，当前分支也存在 merge conflict。

agents/drivers/kafka/src/main/java/com/dbx/agent/kafka/KafkaAgent.java:855 虽然设置了 5 秒 deadline，但第一次 poll(500ms) 返回空集合后，KafkaAgent.java:858 就直接退出。broker、网络或多分区首次 fetch 超过 500ms 时，界面会错误显示“暂无消息”。空 poll 应继续重试到 deadline；只有确认所有 partition position 已到 end offset，或 deadline 到期时才能停止。请补“首次 poll 为空、后续 poll 有数据”的测试。

另外，apps/desktop/src/components/mq/SendMessagePanel.vue:178 会把 1.9 这样的 partition/offset 静默截断为整数。建议使用 Number.isSafeInteger() 并明确拒绝小数和超出安全整数范围的输入。

…lts-mq-i18n Co-authored-by: Cursor <cursoragent@cursor.com> # Conflicts: # apps/desktop/src/i18n/locales/es.ts # apps/desktop/src/i18n/locales/it.ts # apps/desktop/src/i18n/locales/ja.ts # apps/desktop/src/i18n/locales/pt-BR.ts # apps/desktop/src/i18n/locales/zh-TW.ts

Empty first polls no longer abort early; stop only when partitions reach end offsets or the 5s deadline expires. Reject non-safe-integer peek partition/offset inputs instead of truncating decimals. Co-authored-by: Cursor <cursoragent@cursor.com>

xddcode · 2026-07-16T00:42:14Z

已按 review 意见处理：

Merge conflict：当前已合并 origin/main 最新分支，并解决了合并冲突。
Kafka peek 空 poll 误报：collectPeekedMessages 在空 poll 时继续重试，直到各 partition position 到达 end offset，或 5s deadline 到期；补了「首次 poll 为空、后续 poll 有数据」以及 caught-up 提前结束的单测。
partition/offset 校验：改用 Number.isSafeInteger()（parseNonNegativeSafeInteger），明确拒绝小数与超出安全整数范围的输入，不再 Math.floor 静默截断。

t8y2

Re-reviewed the current head and targeted regression coverage. No blocking issues remain.

t8y2 · 2026-07-16T10:20:31Z

Thanks for the contribution! Merged in 68b1777, will be released in the next version.

xddcode and others added 3 commits July 14, 2026 10:18

feat(mq): improve Kafka peek defaults and localize admin console

a4f259f

Make Kafka message peek read all partitions from earliest when partition/offset are omitted, and wire MQ admin UI strings through i18n for all supported locales. Co-authored-by: Cursor <cursoragent@cursor.com>

fix(i18n): make Italian MQ UI terminology consistent

0d7a0fa

Localize ordinary Italian UI nouns on the MQ admin surface while keeping Kafka/Pulsar domain loanwords such as Topic, Broker, Offset, and ISR. Co-authored-by: Cursor <cursoragent@cursor.com>

fix(i18n): align MQ UI nouns across ja/es/pt-BR/zh locales

75db077

Localize ordinary Producer/Consumer and related labels, and clean leftover topic/Permits English in Chinese locales. Co-authored-by: Cursor <cursoragent@cursor.com>

xddcode and others added 5 commits July 14, 2026 10:37

fix(mq): coerce peek partition/offset to string after send

c494e78

Send success returns numbers while the peek filter inputs are string refs for empty optional values. Co-authored-by: Cursor <cursoragent@cursor.com>

Merge pull request #1 from xddcode/feat/settings-about-changelog

d0c499a

feat(settings): embed version changelog in About page

Merge branch 'main' of https://github.com/xddcode/dbx

287fdf6

Merge remote-tracking branch origin/main

03011f2

Resolve changelog both-added conflict by keeping createLatestRequestGuard. Co-authored-by: Cursor <cursoragent@cursor.com>

onceMisery approved these changes Jul 14, 2026

View reviewed changes

Merge branch 't8y2:main' into main

efaf138

t8y2 requested changes Jul 15, 2026

View reviewed changes

xddcode and others added 3 commits July 16, 2026 08:30

Merge branch 't8y2:main' into main

1c291d4

t8y2 approved these changes Jul 16, 2026

View reviewed changes

t8y2 merged commit 68b1777 into t8y2:main Jul 16, 2026
8 checks passed

xddcode deleted the feat/kafka-peek-defaults-mq-i18n branch July 17, 2026 00:43

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat(mq): improve Kafka peek defaults and localize admin console#3375

feat(mq): improve Kafka peek defaults and localize admin console#3375
t8y2 merged 12 commits into
t8y2:mainfrom
xddcode:feat/kafka-peek-defaults-mq-i18n

xddcode commented Jul 14, 2026 •

edited

Loading

Uh oh!

t8y2 commented Jul 14, 2026

Uh oh!

xddcode commented Jul 14, 2026

Uh oh!

onceMisery commented Jul 14, 2026

Uh oh!

onceMisery commented Jul 14, 2026

Uh oh!

t8y2 left a comment

Uh oh!

xddcode commented Jul 16, 2026 •

edited

Loading

Uh oh!

t8y2 left a comment

Uh oh!

Uh oh!

t8y2 commented Jul 16, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Conversation

xddcode commented Jul 14, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

变更说明

1. Kafka 消息查询默认更易用（对应 #3357）

2. MQ 管理台多语言

变更类型

涉及前端

验证

关联 Issue

Uh oh!

t8y2 commented Jul 14, 2026

Uh oh!

xddcode commented Jul 14, 2026

Uh oh!

onceMisery commented Jul 14, 2026

Uh oh!

onceMisery commented Jul 14, 2026

Uh oh!

t8y2 left a comment

Choose a reason for hiding this comment

Uh oh!

xddcode commented Jul 16, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

t8y2 left a comment

Choose a reason for hiding this comment

Uh oh!

Uh oh!

t8y2 commented Jul 16, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

xddcode commented Jul 14, 2026 •

edited

Loading

xddcode commented Jul 16, 2026 •

edited

Loading