1 个仓库
Logic that analyzes offset changes over a specific time window to detect processing delays.
Distinct from Offset Commit Managers: Analyzes offsets over a time window for lag detection, unlike general offset managers that handle the commit process.
Explore 1 awesome GitHub repository matching data & databases · Sliding-Window Evaluators. Refine with filters or upvote what's useful.
Burrow 是一个用于 Kafka 集群的监控和告警服务。它通过评估已提交的偏移量并识别已生产和已消费消息之间的差距来跟踪消费者组的滞后情况。 该系统使用滑动窗口偏移量评估来计算处理延迟,并监控集群的整体健康状况。当消费者组的状态达到预定义阈值时,它会通过电子邮件或 Webhook 向外部服务触发通知。 该服务提供用于查询代理信息和消费者组状态的 HTTP 端点,允许外部工具轮询系统健康和性能指标。
Calculates consumer lag by tracking committed offsets over a specific time interval to detect processing delays.