Version Roadmap

Kafka Log Analyzer evolves through themed releases, each adding monitoring and analysis capabilities.

Current Release

v1.1.0 — Polyglot (Released)

Theme: User Experience Optimization

Capabilities:

• ✅ i18n Support (EN/ZH) — Full internationalization with --locale flag or LOCALE env var (~180 keys). All user-visible strings via t() function.
• ✅ In-Memory Analysis Cache — TTL-based cache with per-source expiry (paste/file: 24h, exporter: 5m, loki: 15m)
• ✅ ASCII Timeline Chart — Stacked bar chart with severity-segmented bars and auto-generated legend. Sparkline in push notifications.
• ✅ Shell Completion — completion command generates scripts for bash/zsh/fish with enum flag suggestions
• ✅ MCP Schema Enhancement — Dynamic analyze_log inputSchema with cluster/group/topic enums from history
• ✅ Folded Markdown Reports — New folded-markdown report format with <details>/<summary> collapsible sections
• ✅ Interactive TUI Browser — --interactive / -i flag for keyboard-driven section navigation
• ✅ Diagnostic Templates — 5 built-in templates with --template flag, templates CLI command, and MCP tools
• ✅ Smart Template Recommendation — recommendTemplates() ranks templates by historical anomaly patterns

v1.0.0 — Architect (Released)

Theme: Production Ready — GA Release

Capabilities:

• ✅ Webhook URL Validation — SSRF protection (HTTPS + private IP rejection) for Feishu and Slack integrations
• ✅ Path Traversal Prevention — sanitizePath() validates file paths, blocks ../ and null byte injection
• ✅ SQLite Parameter Safety — Full audit confirms all queries use prepared statements
• ✅ Secret Redaction in Logs — redact() function masks sensitive values (token, secret, password, key, auth, credential)
• ✅ Test Coverage ≥85% — MCP server integration, event listeners, CLI, dedup, get_lag, JIRA, security, benchmark
• ✅ Benchmark Test — 1MB synthetic log analysis < 5s baseline
• ✅ stdin Piping — Paste mode pipes content via child.stdin instead of temp file I/O
• ✅ Troubleshooting Docs — Error code reference, connection troubleshooting, Python dependency issues
• ✅ Complete API Docs — Request/response examples for all 10 MCP tools (EN + ZH)
• ✅ Deployment Guide Updates — Docker + systemd examples, env var reference table

v0.5.0 — Historian (Released)

Theme: Historical Trends + Persistence

Capabilities:

• ✅ SQLite Persistence — better-sqlite3 powered storage with WAL mode and automatic schema creation
• ✅ Event-Driven Architecture — EventEmitter decouples analysis from persistence and baseline updates
• ✅ Historical Query — query_history tool with time range, source, and cluster filters
• ✅ Trend Comparison — compare_trend tool comparing metrics across time windows
• ✅ Anomaly Multiplier Detection — Automatic ≥ 2× baseline annotation on anomalies
• ✅ Baseline Management — Auto (7-day rolling average) + manual baselines via MCP tools
• ✅ Data Cleanup — Configurable 30-day retention with cleanup_storage tool and daily auto-cleanup

v0.4.0 — Dispatcher (Released)

Theme: Alert Dispatch + Integrations

Capabilities:

• ✅ Grafana alert Hook — Receive Grafana unified/legacy alerting webhook payloads, auto-trigger analysis
• ✅ PagerDuty alert Hook — Parse PagerDuty Events API v2 payloads into normalized analysis triggers
• ✅ Hook HTTP Server — Lightweight server with POST /hooks/grafana, POST /hooks/pagerduty, GET /hooks/health
• ✅ Hook Dedup Engine — Fingerprint-based in-memory dedup with configurable TTL window and merge count
• ✅ Feishu Webhook Push — Send analysis results as interactive card messages to Feishu groups
• ✅ Slack Webhook Push — Send results as Block Kit messages to Slack channels
• ✅ JIRA Integration — Auto-create JIRA issues from analysis with priority mapping
• ✅ Push Dispatcher — Parallel push to all configured targets (Feishu/Slack/JIRA)
• ✅ CLI: hooks — npx kafka-log-analyze hooks [--port P] to start the hook server
• ✅ CLI: push-test — npx kafka-log-analyze push-test [--target feishu|slack|all] to test push
• ✅ MCP Tools — start_hooks, stop_hooks, list_hooks for hook server management
• ✅ Config validators — isFeishuConfigured(), isSlackConfigured(), isJiraConfigured(), isHookServerConfigured()

v0.3.0 — Guardian (Released)

Theme: Prometheus + Kafka Exporter Integration

Capabilities:

• ✅ Prometheus connector — PromQL query client (queryInstant, queryRange, fetchLag, fetchBrokerMetrics, fetchExporterEvents)
• ✅ Loki connector — LogQL query client (queryRange, fetchKafkaLogs)
• ✅ get_lag tool — Full implementation fetching consumer lag from Prometheus/Kafka Exporter
• ✅ analyze_log source:exporter — Analyze live metrics with anomaly detection on lag data
• ✅ analyze_log source:loki — Query Kafka logs via LogQL, reuse Python analysis pipeline
• ✅ MCP Resources — Live metric streams (kafka://metrics/{cluster}, kafka://lag/{cluster})
• ✅ CLI commands — analyze-exporter and analyze-loki for direct data source access
• ✅ Graceful degradation — Empty data + friendly warnings when sources are unreachable
• ✅ Config validators — isPrometheusConfigured(), isLokiConfigured(), validateSourceConfig()

v0.2.1 (Released)

Theme: Bug Fixes + CI Hardening

Changes:

• 🐛 Fixed temp file race condition in analyzeLog (UUID replaces Date.now())
• 🐛 Fixed CLI integration test commands (analyze <file> subcommand syntax)
• 🐛 Fixed release workflow: previous_version output, first-release tag fallback, heredoc delimiter
• 🐛 Fixed release workflow permissions (contents: write)
• 🐛 Fixed Python test imports to match actual module APIs
• 🐛 Fixed ESLint errors: no-undef in format tests, no-conditional-expect in analyze_log tests
• 🔧 Unified all CI steps to use pnpm instead of npm
• 🔧 Upgraded action-gh-release v1→v2, codecov-action v3→v4
• 🔧 Removed insecure snyk/actions/node@master floating tag
• 🔧 Added --prod to pnpm audit to exclude dev-only vulns (vitepress)
• 🔧 Translated CHANGELOG from Chinese to English

v0.2.0 — Watchtower (Released)

Theme: Enhanced Commands + CLI

Capabilities:

• ✅ Focus area filtering (--focus producer,consumer,broker,lag,error)
• ✅ Timeline analysis with configurable windows (1m, 5m, 15m, 1h, 6h, 1d)
• ✅ Priority filtering (--priority P0,P1)
• ✅ Unified report formats (--report markdown/json/slack)
• ✅ MCP Tool new parameters: priority, report
• ✅ Enhanced error handling with AnalyzerError class
• ✅ --debug CLI flag for verbose logging

v0.1.0 — Sentinel (Released)

Theme: Core Analysis Engine

Capabilities:

• ✅ analyze_log tool — Parse logs, detect anomalies, classify priorities
• ✅ Multi-format support — Text and JSON Kafka logs
• ✅ 11 event types — send_success, send_failure, consumer_lag, rebalance, etc.
• ✅ 7 anomaly detectors — Error spikes, rebalance storms, lag spikes, etc.
• ✅ Priority classification — P0-P3 automatic grading
• ✅ Multiple output formats — Markdown, JSON, Slack
• ✅ /kafka-analyze command — Claude Code skill integration
• ✅ CLI with zero-install npx support

Use Cases:

• Quick log analysis during incidents
• Automated anomaly detection
• Team collaboration via formatted reports

Planned Releases

No planned releases yet. Future roadmap will be shaped by community feedback. v1.1.0 was the first community-driven release, focusing on internationalization, visualization, and interactive workflows.

Release Philosophy

• Incremental Value: Each release delivers usable features
• Backward Compatible: APIs remain stable across minor versions
• Community Driven: Roadmap shaped by user feedback

Contributing

Have ideas for future releases? Open an issue or join discussions.

Changelog

See CHANGELOG.md for release history.