基于 kafkajs 的 Kafka 可视化管理客户端：多连接管理、集群概览、Topic 全生命周期、消息浏览与实时跟随、消息发送、消费组 Lag 分析。数据直连 Kafka Broker，纯本地运行，不经过任何第三方服务器。

## ✨ 核心功能

### 连接管理
- **多连接**：保存任意多个集群连接，一键切换，自动重连
- **协议支持**：无认证 / SASL PLAIN / SCRAM-SHA-256 / SCRAM-SHA-512，可叠加 SSL/TLS
- **密码安全**：密码字段 AES-256-GCM 加密后存入 uTools 本地数据库，不落明文
- **多 Broker**：填一个 seed 地址即可自动发现集群全部节点

### 集群概览
- Broker 列表（节点 ID / 主机 / 端口 / Controller 标记）
- Topic 总数、分区总数、内置 Topic 统计

### Topic 管理
- 列表：名称过滤、分区数、副本数、内置 Topic 标记
- **消息量统计**：懒加载（low~high 求和），不拖慢列表
- **详情**：各分区 Leader / 副本 / ISR（落后 ISR 红色预警）/ 首末位移 / 消息量
- **全生命周期**：创建（分区 / 副本 / cleanup.policy / retention.ms）、删除（二次确认）、配置查看与在线修改
- 一键跳转「浏览消息」

### 消息工具
- **有界读取**：指定 Topic / 分区 / 起点（earliest、latest、指定位移）+ 条数上限，按 offset 升序展示
- **实时跟随**：从最新位置持续监听新消息（类似 `tail -f`），随时停止
- **消息详情**：JSON 自动美化高亮、Headers、Key、大小、十六进制预览（二进制安全）
- **导出**：JSONL 一键导出；单条消息另存
- **发送消息**：指定 Topic / 分区 / Key / Headers，JSON 格式化、实时字节数

### 消费组
- 组列表 + 状态标签（稳定 / 再平衡中 / 空等中文说明）
- **详情**：成员列表及 Topic[分区] 分配明细（自行解析 CProtocol 分配协议）
- **Lag 分析**：逐 Topic-分区的已提交位移 / LEO / Lag，堆积红色预警，汇总总 Lag
- 删除消费组（清理位移）

### AI 能力（MCP 工具）
内置 9 个 MCP 工具，uTools AI Agent 可直接查询 Kafka：