Releases: Bronya0/Kafka-King
Releases · Bronya0/Kafka-King
Release list
v0.47 发布 🎉
v0.47 正式版发布 🎉 （macOS 用户如果遇到“已损坏”无法打开，终端执行 xattr -dr com.apple.quarantine /Applications/Kafka-King.app 即可，原因是 app 未签名）
感谢大家的支持！Kafka-King 迎来重大版本 v0.47。本次发布涵盖了 Schema Registry 支持、无消费组直连消费模式、多路流式消费、消费组 Offset 重置、消息清理（DeleteRecords）、分区副本重分配、Broker 节点与配额管理、连接配置导入导出，以及多项底层并发安全重构与稳定性优化。
🌟 核心新增功能
1. 消费能力大幅升级与无组直连消费
- 无消费组直连消费（Direct Consume）：消费组改为非必填（默认留空），直连拉取分区消息，不向 Broker 注册 Consumer Group、不触发 Rebalance、彻底避免在集群产生大量无用的僵尸消费组元数据
- 位移提交安全联动：无消费组模式下自动禁用
Commit Offset开关并展示提示，清空消费组时自动关闭位移提交，防止误操作 - 多路并行流式消费：支持同时订阅多个不同的流，每路流拥有完全独立的底层客户端与生命周期，支持多流 Tab 标签切换查看、实时速率统计（msg/s）与自动滚屏
- 消息回放与导出：支持将筛选或选中的消息直接重新发送至指定目标 Topic，支持将消费结果一键导出为 JSON / CSV
- 灵活的起始位移：新增指定绝对 Offset 起始消费（对各分区生效），支持按具体时间戳起始消费，本地检索支持正则表达式
2. Schema Registry 与高级消息解码
- 独立管理页面：新增 Schema Registry 管理页面，支持 Subject 列表与版本详情浏览、全局及 Subject 兼容性级别（Compatibility Level）设置、Subject/Version 软硬删除
- 多格式自动解码：消费端深度集成 Confluent Wire Format，识别 5 字节协议头并自动调用 Registry 拉取 Schema，支持 Avro（反序列化为格式化 JSON 展示）、JSON Schema 与 Protobuf 解码
3. 集群运维管控与副本管理
- 消费组 Offset 重置：支持重置为 Start（最早）、End（最新）、指定时间戳或指定绝对 Offset，重置前自动解绑断开本应用已占用的消费者
- 消息清理（DeleteRecords）：支持清理指定分区或全部分区至目标位移，支持一键安全删除当前全部已存在消息（offset=-1），越界自动安全钳制
- 分区副本重分配：可视化查看与调整分区副本拓扑分布（AlterPartitionAssignments），支持取消正在进行的重分配任务
- 节点增强与配额管理：Broker 列表标记 Controller / KRaft 节点，新增各 Broker 日志目录（LogDirs）磁盘空间占用分析，支持 Client Quotas 客户端配额动态配置与查询
4. 连接管理与认证扩展
- 连接配置一键导入/导出：支持将所有保存的集群连接配置一键导出为 YAML，并支持从 YAML/JSON 导入，支持智能去重、覆盖更新与 ID 分配
- 扩展认证机制：支持 OAUTHBEARER（静态 Token 模式）以及 AWS MSK IAM 认证，完善 Kerberos（GSSAPI）配置
5. UI、文档与生态
- 关于页与各语言文档新增开源桌面级 AI 编程助手 Ally Agent 项目指引
- 优化集群连接卡片悬浮动效与切换引导，主题切换体验更顺畅
- 多语言支持：新增了德语、西班牙语、法语、印尼语、意大利语、葡萄牙语、越南语等多语言 README，界面补齐英文、日文、韩文、俄文翻译
🛠️ 缺陷修复与稳定性提升
- 页面假死：修复 Topics 页面在搜索过滤后点击 Topic 详情可能触发 loading 遮罩永久卡死的问题
- 并发竞态消除：后端所有管理方法全面采用
adminClient()/clients()锁内快照机制，彻底消除与集群切换及断开连接时的数据竞争；单次消费引入oneShotMu串行化隔离，杜绝底层客户端并发PollRecords的未定义行为 - 字段持久化：修复
types.Connect结构体缺少use_kerberos与sasl_session_token导致保存配置被静默丢弃的问题 - 对话框入参：修复 Wails 原生文件选择与保存对话框的文件后缀过滤参数不匹配问题
- 表格编辑串值：ShowOrEdit 单元格双击重置输入框状态，彻底修复跨行编辑串值提交问题
- 巡检监控优化：修复 Monitor 页面修改轮询间隔时未开始巡检就偷跑请求的问题，切换集群时自动停止当前巡检
- 分区器重构：引入
autoPartitioner优先尊重显式指定分区，回退至 sticky-key 分区，解决消息钉死在分区 0 的问题 - 窗口自适应：修复启动时窗口尺寸自适应问题
🏗️ 底层框架与工程化升级
- 核心框架升级至 Wails v2.15.0，编译与 CI 构建环境全面对齐 Go 1.25 与 Node 22
- Kafka 客户端引擎
franz-go升级至v1.21.6 - 引入
kfake/srfake内存假集群全套单元测试体系，核心链路覆盖自动化回归 - GitHub Actions CI 工作流全面升级现代化 Action 依赖
开源免费 AI 编程助手：https://github.com/Bronya0/ally-agent 欢迎体验！
v0.47-beta.2 预发布测试 🚀
v0.47-beta.2 预发布测试 🚀 （macOS 用户如果遇到“已损坏”无法打开，终端执行 xattr -dr com.apple.quarantine /Applications/Kafka-King.app 即可，原因是 app 未签名）
本次版本涵盖了自 v0.46 以来累计的重大功能升级、架构重构与稳定性修复。
🌟 新增功能与体验升级
1. 消费端无消费组直连（Direct Consume）与位移联动（New ✨）
- 无消费组直连模式：消费组改为非必填（默认留空），直连拉取分区消息，不向 Broker 注册 Consumer Group、不触发 Rebalance、彻底避免在集群产生大量无用的僵尸消费组
- 位移提交安全联动：无消费组模式下自动禁用 Commit Offset 开关并展示禁用提示，清空消费组时自动关闭位移提交
- 交互与国际化完善：消费组增加无组消费提示 Tooltip 与占位符，同步支持中、英、日、韩、俄五种语言；修复 LogDirs 页面文案靠左对齐
2. Schema Registry 与高级消息解码
- 新增 Schema Registry 独立管理页面：支持 Subject 及其版本浏览、全局与 Subject 兼容级别设置、删除等操作
- 消费端支持多种 Wire Format 解码：
- Avro：集成 Confluent 格式解码并解析为 JSON 展示
- JSON 与 Protobuf 解码支持
3. 运维管控与副本管理
- 消费组 Offset 重置：支持按 Start（最早）、End（最新）、指定时间戳（毫秒）以及指定绝对 Offset 进行重置；重置前自动解绑并断开本应用已占用的消费者
- 消息清理（DeleteRecords）：支持清理指定分区或全部分区至指定水位，支持一键删除当前全部已存在消息（offset=-1），越界自动安全钳制
- 分区副本重分配：通过 AlterPartitionAssignments 调整分区副本分布，预填当前拓扑，支持取消正在进行的重分配
- 节点视图（Nodes）增强：支持 KRaft / Controller 节点标记、各 Broker LogDirs 磁盘目录占用空间展示、Client Quotas 客户端配额查询与动态修改
4. 多路流式消费与消费能力升级
- 多路并行流式消费：每路流拥有完全独立的底层客户端与生命周期管理，支持活跃流标签多标签切换查看
- 流式消费 Offset 提交修复并增加 15s 超时保护
- 单次消费引入 oneShotMu 串行化隔离，杜绝底层客户端并发 PollRecords 的未定义行为
- 消费支持按指定 Offset 起始消费，本地过滤支持正则表达式过滤
- 消息回放支持：支持将选中的消息直接重新发送至目标 Topic，支持消息导出为 JSON
5. 连接管理与导出导入
- 连接配置导入与导出：支持全部连接配置一键导出为 YAML，并支持从 YAML/JSON 文件导入，支持智能去重、覆盖更新与 ID 分配
- 认证方式扩展：新增支持 OAUTHBEARER（静态 Token 模式）以及 AWS MSK IAM 认证，完善 Kerberos（GSSAPI）配置
6. UI、文档与生态联动
- 关于页与各语言 README 新增开源桌面 AI 编程助手 Ally Agent 项目指引
- 全面更新 12 种语言版本 README 功能清单
- 集群卡片悬浮与切换引导动效优化，深浅色主题切换更顺畅
🛠️ 缺陷修复与稳定性提升
- 页面假死：修复 Topics 页面在搜索过滤后点击 Topic 详情可能触发 loading 遮罩永久卡死的问题
- 并发竞态：后端所有管理方法全面采用
adminClient()/clients()锁内快照机制，彻底消除与集群切换及断开连接时的数据竞争 - 字段持久化：修复
types.Connect结构体缺少use_kerberos与sasl_session_token导致保存配置被静默丢弃的问题 - 对话框入参：修复 Wails 原生文件选择与保存对话框的文件后缀过滤参数不匹配问题
- 表格编辑：ShowOrEdit 单元格双击重置输入框状态，彻底修复跨行编辑串值提交问题
- 巡检监控：修复 Monitor 页面修改轮询间隔时未开始巡检就偷跑请求的问题，切换集群时自动停止当前巡检
- 分区器重构：引入 autoPartitioner 优先尊重显式指定分区，回退至 sticky-key 分区，解决消息钉死在分区 0 的问题
- 国际化补全：全面补齐英文、日文、韩文、俄文等多语言缺失翻译
🏗️ 依赖与底层升级
- 框架升级至 Wails v2.15.0，编译与 CI 环境统一对齐 Go 1.25
- 引入
kfake/srfake假集群单元测试体系，测试不再依赖外部真实集群 - franz-go 升级至
v1.21.6，CI 工作流全面升级现代化 Action 依赖
开源免费 AI 编程助手：https://github.com/Bronya0/ally-agent 欢迎体验！
v0.47-beta 预发布测试 🚀
v0.47-beta 预发布测试 🚀 （macOS 用户如果遇到“已损坏”无法打开，终端执行 xattr -dr com.apple.quarantine /Applications/Kafka-King.app 即可，原因是 app 未签名）
本次版本涵盖了自 v0.46 以来累计的重大功能升级、架构重构与稳定性修复。
🌟 新增功能
1. Schema Registry 与高级消息解码
- 新增 Schema Registry 独立管理页面：支持 Subject 及其版本浏览、全局与 Subject 兼容级别设置、删除等操作
- 消费端支持多种 Wire Format 解码：
- Avro：集成 Confluent 格式解码并解析为 JSON 展示
- JSON 与 Protobuf 解码支持
2. 运维管控与副本管理
- 消费组 Offset 重置：支持按 Start（最早）、End（最新）、指定时间戳（毫秒）以及指定绝对 Offset 进行重置；重置前自动解绑并断开本应用已占用的消费者
- 消息清理（DeleteRecords）：支持清理指定分区或全部分区至指定水位，支持一键删除当前全部已存在消息（offset=-1），越界自动安全钳制
- 分区副本重分配：通过 AlterPartitionAssignments 调整分区副本分布，预填当前拓扑，支持取消正在进行的重分配
- 节点视图（Nodes）增强：支持 KRaft / Controller 节点标记、各 Broker LogDirs 磁盘目录占用空间展示、Client Quotas 客户端配额查询与动态修改
3. 多路流式消费与消费能力升级
- 多路并行流式消费：每路流拥有完全独立的底层客户端与生命周期管理，支持活跃流标签多标签切换查看
- 流式消费 Offset 提交修复并增加 15s 超时保护
- 单次消费引入 oneShotMu 串行化隔离，杜绝底层客户端并发 PollRecords 的未定义行为
- 消费支持按指定 Offset 起始消费，本地过滤支持正则表达式过滤
- 消息回放支持：支持将选中的消息直接重新发送至目标 Topic，支持消息导出为 JSON
4. 连接管理与导出导入
- 连接配置导入与导出：支持全部连接配置一键导出为 YAML，并支持从 YAML/JSON 文件导入，支持智能去重、覆盖更新与 ID 分配
- 认证方式扩展：新增支持 OAUTHBEARER（静态 Token 模式）以及 AWS MSK IAM 认证，完善 Kerberos（GSSAPI）配置
5. UI 与生态联动
- 关于页新增开源桌面 AI 编程助手 Ally Agent 项目指引卡片
- 集群卡片悬浮与切换引导动效优化，深浅色主题切换更顺畅
🛠️ 缺陷修复与稳定性提升
- 页面假死：修复 Topics 页面在搜索过滤后点击 Topic 详情可能触发 loading 遮罩永久卡死的问题
- 并发竞态：后端所有管理方法全面采用 �dminClient() / clients() 锁内快照机制，彻底消除与集群切换及断开连接时的数据竞争
- 字段持久化：修复 ypes.Connect 结构体缺少 use_kerberos 与 sasl_session_token 导致保存配置被静默丢弃的问题
- 对话框入参：修复 Wails 原生文件选择与保存对话框的文件后缀过滤参数不匹配问题
- 表格编辑：ShowOrEdit 单元格双击重置输入框状态，彻底修复跨行编辑串值提交问题
- 巡检监控：修复 Monitor 页面修改轮询间隔时未开始巡检就偷跑请求的问题，切换集群时自动停止当前巡检
- 分区器重构：引入 autoPartitioner 优先尊重显式指定分区，回退至 sticky-key 分区，解决消息钉死在分区 0 的问题
- 国际化补全：全面补齐英文、日文、韩文、俄文等多语言缺失翻译
🏗️ 依赖与底层升级
- 框架升级至 Wails v2.15.0，编译与 CI 环境统一对齐 Go 1.25
- 引入 kfake / srfake 假集群单元测试体系，测试不再依赖外部真实集群
- franz-go 升级至 �1.21.6，CI 工作流全面升级现代化 Action 依赖
开源免费 AI 编程助手：https://github.com/Bronya0/ally-agent 欢迎体验！
v0.46 发布
v0.46 发布🎉 （macOS 用户如果遇到“已损坏”无法打开，终端执行 xattr -dr com.apple.quarantine /Applications/Kafka-King.app 即可（原因是 app 未签名）
新增
Topic跳转回显
- Topic列表点击"生产消息"/"查看消费消息"按钮跳转时，自动预选对应topic
- 生产/消费页 topic 下拉选择变更自动缓存到 localStorage
- 切连接时自动清理缓存，按连接独立记忆
流式订阅消费正式发布
- RAF 节流渲染，避免高频消息导致重复 DOM 更新
- 消息列表倒序显示（最新在上）
- 内存保护：200MB 大小上限 + 10000 条数量上限
- 累计总接收数与当前缓存数分开显示
- 缓存信息悬浮提示 + 多语言国际化
修复
SSH隧道多Broker连接
- 重写SSH隧道实现，使用 kgo.Dialer 替代本地TCP监听
- 所有Kafka broker连接（包括元数据发现的新broker）都通过跳板机路由
- 修复仅第一个 bootstrap server 走隧道、其余直连超时的问题
ACL列表为空
- 修复
kadm.NewACLs()零值过滤器导致 DescribeACLs 发送空请求的bug - 添加 AnyResource + Operations + ACLPatternAny 匹配全部ACL
其他
- 消费参数（Group/Number/Timeout）按连接缓存到 localStorage
- 解码默认值改为 utf8，语义更准确
- 过滤 consumer 正常关闭的 DeadlineExceeded/Canceled 错误误报
我的新作，开源免费AI 编码agent：https://github.com/Bronya0/ally-agent 欢迎体验使用
v0.45.alpha.2
v0.45.alpha.2 测试版本勿用生产环境，请用稳定版
v0.45 alpha测试
【测试版本，可能有bug，请下稳定版】
新增流式消费功能，支持订阅、停止和状态显示；更新国际化文件；调整前端开发服务器端口
新增 AGENTS.md 文件，包含项目概述、开发命令、架构、重要约定及测试信息
v0.44 发布🎉
v0.43
- 升级wails 和 franz-go版本
- 增加查看消费者组订阅了哪些主题及分区
- 修复消费者表格对header为json时解析为object的问题 @FOOLSIX
- 修复消费者界面，无法导出消费的消息
- 重构代码，提高稳定性
q群高速下载：964440643
- Upgraded wails and franz-go versions
- Added the ability to view topics and partitions subscribed to a consumer group
- Fixed an issue with the consumer table parsing JSON headers as objects (@FOOLSIX)
- Fixed an issue with the consumer interface, preventing the export of consumed messages
- Refactored code to improve stability
Contributors
FOOLSIX
Assets 5
v0.42
- 实现 ACL机制（Beta测试）
- 消费者组支持搜索
- 增加macos下的dmg发布
- 修复生产者指定分区号不生效的问题
- 升级wails版本
- 缓存分页尺寸
- 重构进程信息显示
- 解决监控界面图例压盖问题 @dk333
- 解决设置界面ProcessInfo在亮主题下显示异常问题 @dk333
- 增加监控方案管理功能 @dk333
q群高速下载：964440643
- Implement ACL mechanism (Beta test)
- Support search in consumer groups
- Add dmg release under macos
- Fix the problem that the producer-specified partition number does not take effect
- Upgrade wails version
- Cache paging size
- Refactor process information display
- Solve the problem of legend overlap in monitoring interface @dk333
- Solve the problem that ProcessInfo in setting interface displays abnormally under light theme @dk333
- Add monitoring solution management function @dk333
Contributors
dk333