介绍

智能 Kafka 日志分析，支持 Claude Code — 异常检测、优先级分类和可操作建议。

快速链接

• 安装 — 几分钟内开始使用
• 快速开始 — 体验核心功能
• API 参考 — MCP Tools 文档
• 路线图 — 版本计划

解决什么问题？

传统的 Kafka 调试需要手动 grep 日志：

grep ERROR server.log | wc -l
# → 156 个错误，但规律是什么？

它无法回答的问题：

• 哪些错误是关键的，哪些是噪声？
• 事件的时间线是什么？
• 我应该采取什么行动？
• 如何与团队分享发现？

解决方案

Kafka Log Analyzer 通过三层提供智能分析：

层级	能力	输出
日志解析	从 Kafka 日志中提取事件	11 种事件类型 + 元数据
异常检测	7 种内置检测器	优先级分类结果（P0-P3）
报告生成	多种格式	Markdown、JSON、Slack 格式

核心特性

📊 智能日志分析

• 多格式支持 — 解析文本和 JSON Kafka 日志
• 11 种事件类型 — send_success、send_failure、consumer_lag、rebalance 等
• 7 种异常检测器 — 错误率突增、Rebalance 风暴、Lag 激增、Leader 不稳定、副本延迟、序列化问题、网络问题

🎯 优先级分类

自动严重程度分级：

优先级	严重程度	示例
🟢 P0（严重）	集群宕机	完整的 Broker 故障
🟡 P1（高）	高积压	Consumer Lag > 10K 条消息
🟠 P2（中）	瞬时问题	Leader 变更、临时错误
🔴 P3（低）	警告	配置警告、调试日志

🔄 多种输出格式

• Markdown — 带章节和推荐的详细报告
• JSON — 用于程序化处理的结构化数据
• Slack — 为团队频道优化的紧凑格式

🖥️ Claude Code 集成

在 Claude Code 中使用自然语言命令：

命令	用途
/kafka-analyze	分析日志并检测异常

输出示例

/kafka-analyze --source file --path server.log

📊 正在分析 server.log...

📋 摘要:
  总事件数: 847
  P0（严重）: 3
  P1（高）: 12

⚠️ 异常:
  🔴 send_failure_spike (P0)
     → 错误率 15% 超过阈值 (5%)
     → 检查 Broker 可用性和网络连接

  🟠 consumer_lag (P1)
     → 消费者组 order-processor 积压: 15,000 条消息
     → 考虑扩展消费者实例

💡 建议:
  1. 检查 Broker 可用性
  2. 审查消费者组配置

对比

维度	grep/awk	Kafka Log Analyzer
输出	原始文本行	结构化 Event[] + 异常
异常	❌ 手动发现	✅ 7 种内置检测器
优先级	❌ 无	✅ P0-P3 自动分级
时间线	❌ 无	✅ 时间窗口分布
建议	❌ 无	✅ 可操作的修复建议

开始使用

选择你的方式：

1. Claude Code 插件（推荐）

# 插件市场
/plugin marketplace add saqqdy/kafka-log-analyzer
/plugin install kafka-log-analyzer

2. CLI（零安装）

npx kafka-log-analyze --source file --path server.log

3. 克隆与探索

git clone https://github.com/saqqdy/kafka-log-analyzer.git
cd kafka-log-analyzer
pnpm install
pnpm run build
node dist/cli.js --source file --path tests/fixtures/sample-kafka-log.txt

项目状态

版本	主题	状态
v0.1.0	核心分析引擎	✅ 已发布
v0.2.0	增强命令 + CLI	✅ 已发布
v0.3.0	Prometheus + Kafka Exporter 集成	✅ 已发布
v0.4.0	告警调度 + 推送集成	✅ 已发布
v0.5.0	历史趋势 + 持久化	✅ 已发布
v1.0.0	安全加固 + 生产就绪	✅ 已发布

详见路线图。

许可证

MIT — 可自由用于个人和商业项目。