EFAK-AI 简介

EFAK-AI（原名 Kafka Eagle）是一款开源的Kafka监控与管理工具，专注于提供可视化界面和智能化分析功能。其核心目标是通过实时监控、告警、性能分析等功能，帮助用户高效管理Kafka集群。

核心功能

集群监控

• 实时展示Broker、Topic、Consumer Group的状态，包括消息堆积、分区分布等指标。
• 支持多集群管理，可通过统一界面切换不同Kafka环境。

智能告警

• 基于阈值或异常检测触发告警，支持邮件、钉钉、企业微信等通知渠道。
• 提供消息延迟、副本同步失败等关键指标的预警功能。

性能分析

• 内置流量分析模块，可统计Topic的TPS（吞吐量）和消息大小分布。
• 支持历史数据存储与趋势图表生成，便于容量规划。

数据治理

• 提供消息内容预览和检索功能，支持按Offset或时间戳查询。
• 自动识别空闲Topic和低效Consumer，辅助资源优化。

技术架构

• 前端：基于Vue.js构建，响应式设计支持多端访问。
• 后端：使用Spring Boot框架，通过JMX和Kafka API采集数据。
• 存储：依赖MySQL存储元数据，可选配Prometheus存储时序数据。

部署方式

独立部署

• 下载二进制包或通过Docker镜像快速启动，需配置KE_CONFIG环境变量指定数据源。
• 支持Zookeeper和Kafka自身的协调服务（KRaft模式）。

集成扩展

• 与Prometheus和Grafana集成，扩展监控仪表盘能力。
• 提供OpenAPI接口，支持二次开发定制。

适用场景

• 需要快速定位Kafka消息堆积或延迟问题的运维团队。
• 开发人员调试Consumer逻辑时，需直观查看消息内容。
• 企业级多集群管理场景，要求统一的监控入口。

社区与资源

• 开源地址：GitHub仓库提供详细文档和社区支持。
• 更新活跃，定期发布新版本增强AI分析能力（如自动调优建议）。

通过EFAK-AI，用户可显著降低Kafka运维复杂度，尤其适合中大规模集群的场景。