Skip to content

版本路线图

Kafka Log Analyzer 通过主题化迭代逐步演进,每个版本增加监控和分析能力。

当前版本

v1.1.0 — Polyglot(已发布)

主题:用户体验优化

功能

  • ✅ i18n 国际化(EN/ZH) — 通过 --locale 标志或 LOCALE 环境变量切换语言(~120 条翻译)。所有用户可见字符串通过 t() 函数处理。
  • ✅ 内存分析缓存 — 基于TTL的缓存,按数据源类型自动过期(粘贴/文件:24h,exporter:5m,loki:15m)
  • ✅ ASCII 时间线图表 — 堆叠柱状图按严重级别分色显示,自动生成图例。推送通知中嵌入迷你趋势图。
  • ✅ Shell 补全 — completion 命令生成 bash/zsh/fish 补全脚本,支持所有枚举参数
  • ✅ MCP Schema 增强 — 动态 analyze_log 输入Schema,集群/消费者组/主题枚举从历史数据自动填充
  • ✅ 折叠 Markdown 报告 — 新增 folded-markdown 报告格式,使用 <details>/<summary> 折叠区块
  • ✅ 交互式 TUI 浏览器 — --interactive / -i 标志启动键盘驱动的章节浏览器
  • ✅ 诊断模板 — 5 个内置模板(lag-diagnosisrebalance-stormproducer-errorsbroker-healthfull-audit)。--template <id> 标志和 templates CLI 命令
  • ✅ 智能模板推荐 — recommendTemplates() 基于历史异常模式对模板排序。新增 MCP 工具 diagnoselist_templates

v1.0.0 — Architect(已发布)

主题:生产就绪 — GA 版本

功能

  • ✅ Webhook URL 验证 — SSRF 防护(强制 HTTPS + 拒绝私有 IP)应用于飞书和 Slack 集成
  • ✅ 路径遍历防护 — sanitizePath() 验证文件路径,阻止 ../ 和 null 字节注入
  • ✅ SQLite 参数安全 — 完整审计确认所有查询使用预编译语句
  • ✅ 日志密钥脱敏 — redact() 函数自动遮蔽敏感值(token、secret、password、key、auth、credential)
  • ✅ 测试覆盖率 ≥85% — MCP 服务器集成、事件监听、CLI、去重、get_lag、JIRA、安全、性能基准
  • ✅ 性能基准测试 — 1MB 合成日志分析 < 5秒基线
  • ✅ stdin 管道 — 粘贴模式通过 child.stdin 管道传输内容,替代临时文件 I/O
  • ✅ 故障排除文档 — 错误码参考、连接故障排除、Python 依赖问题
  • ✅ 完善 API 文档 — 所有 10 个 MCP 工具的请求/响应示例(中英文)
  • ✅ 部署指南更新 — Docker + systemd 示例,环境变量参考表

v0.5.0 — Historian(已发布)

主题:历史趋势 + 持久化

功能

  • ✅ SQLite 持久化 — better-sqlite3 驱动,WAL 模式,自动建表
  • ✅ 事件驱动架构 — EventEmitter 解耦分析与持久化、基线更新
  • ✅ 历史查询 — query_history 工具支持按时间范围、来源、集群过滤
  • ✅ 趋势对比 — compare_trend 工具对比时间段指标
  • ✅ 异常倍数检测 — 当前值 ≥ 基线 2 倍时自动标注
  • ✅ 基线管理 — 自动基线(7 天滚动均值)+ 手动基线覆盖
  • ✅ 数据清理 — 可配置 30 天保留策略 + cleanup_storage 工具 + 每日自动清理

v0.4.0 — Dispatcher(已发布)

主题:告警调度 + 集成

功能

  • ✅ Grafana 告警 Hook — 接收 Grafana Webhook,自动触发分析
  • ✅ PagerDuty 告警 Hook — 解析 PagerDuty Events API v2 告警
  • ✅ Hook HTTP 服务器 — POST /hooks/grafanaPOST /hooks/pagerdutyGET /hooks/health
  • ✅ Hook 去重引擎 — 基于 fingerprint 的内存去重、可配置 TTL 和合并计数
  • ✅ 飞书 Webhook 推送 — 交互卡片消息推送到飞书群
  • ✅ Slack Webhook 推送 — Block Kit 格式推送到 Slack 频道
  • ✅ JIRA 集成 — 自动创建 JIRA Issue,含优先级映射
  • ✅ 推送调度器 — 并行推送到所有已配置目标(飞书/Slack/JIRA)
  • ✅ CLI: hooksnpx kafka-log-analyze hooks [--port P] 启动 Hook 服务器
  • ✅ CLI: push-testnpx kafka-log-analyze push-test [--target feishu|slack|all] 测试推送
  • ✅ MCP 工具 — start_hooksstop_hookslist_hooks 管理 Hook 服务器
  • ✅ 配置校验 — isFeishuConfigured()isSlackConfigured()isJiraConfigured()isHookServerConfigured()

v0.3.0 — Guardian(已发布)

主题:Prometheus + Kafka Exporter 集成

功能

  • ✅ Prometheus 连接器 — PromQL 查询客户端(queryInstantqueryRangefetchLagfetchBrokerMetricsfetchExporterEvents
  • ✅ Loki 连接器 — LogQL 查询客户端(queryRangefetchKafkaLogs
  • get_lag 工具 — 从 Prometheus/Kafka Exporter 获取消费积压
  • analyze_log source:exporter — 分析实时指标,检测积压异常
  • analyze_log source:loki — 通过 LogQL 查询 Kafka 日志,复用 Python 分析管线
  • ✅ MCP Resources — 实时指标流(kafka://metrics/{cluster}kafka://lag/{cluster}
  • ✅ CLI 命令 — analyze-exporteranalyze-loki 直接访问数据源
  • ✅ 优雅降级 — 数据源不可达时返回空数据 + 友好警告
  • ✅ 配置校验 — isPrometheusConfigured()isLokiConfigured()validateSourceConfig()

v0.2.1(已发布)

主题:Bug 修复 + CI 加固

变更

  • 🐛 修复 analyzeLog 临时文件竞态条件(UUID 替代 Date.now()
  • 🐛 修复 CLI 集成测试命令(analyze <file> 子命令语法)
  • 🐛 修复发布工作流:previous_version 输出、首次发布 tag 回退、heredoc 分隔符
  • 🐛 修复发布工作流权限(contents: write
  • 🐛 修复 Python 测试导入以匹配实际模块 API
  • 🐛 修复 ESLint 错误:格式测试中的 no-undef,analyze_log 测试中的 no-conditional-expect
  • 🔧 统一 CI 步骤使用 pnpm 替代 npm
  • 🔧 升级 action-gh-release v1→v2、codecov-action v3→v4
  • 🔧 移除不安全的 snyk/actions/node@master 浮动标签
  • 🔧 pnpm audit 添加 --prod 排除开发依赖漏洞(vitepress)
  • 🔧 将 CHANGELOG 从中文翻译为英文

v0.2.0 — Watchtower(已发布)

主题:增强命令 + CLI

功能

  • ✅ 关注领域过滤(--focus producer,consumer,broker,lag,error
  • ✅ 时间线分析,可配置窗口(1m5m15m1h6h1d
  • ✅ 优先级过滤(--priority P0,P1
  • ✅ 统一报告格式(--report markdown/json/slack
  • ✅ MCP 工具新参数:priorityreport
  • ✅ 增强错误处理,AnalyzerError
  • --debug CLI 标志,详细日志

v0.1.0 — Sentinel(已发布)

主题:核心分析引擎

功能

  • analyze_log 工具 — 解析日志、检测异常、分类优先级
  • ✅ 多格式支持 — 文本和 JSON Kafka 日志
  • ✅ 11 种事件类型 — send_success、send_failure、consumer_lag、rebalance 等
  • ✅ 7 种异常检测器 — 错误率突增、Rebalance 风暴、积压激增等
  • ✅ 优先级分类 — P0-P3 自动分级
  • ✅ 多种输出格式 — Markdown、JSON、Slack
  • /kafka-analyze 命令 — Claude Code 技能集成
  • ✅ CLI 零安装 npx 支持

计划版本

暂无计划版本。未来路线图将由社区反馈决定。v1.1.0 是首个社区驱动版本,聚焦国际化、可视化与交互式工作流。

发布理念

  • 增量价值:每个版本交付可用功能
  • 向后兼容:次版本间 API 保持稳定
  • 社区驱动:路线图基于用户反馈演进

贡献

对未来版本有想法?提交 Issue 或参与讨论。

变更日志

查看 CHANGELOG.md 了解版本历史。

基于 MIT 许可发布