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 is a monitoring and alerting service for Kafka clusters. It tracks consumer group lag by evaluating committed offsets and identifying the gap between produced and consumed messages. The system calculates processing delays using a sliding-window offset evaluation and monitors overall cluster health. When consumer group conditions meet predefined thresholds, it triggers notifications to external services via email or webhooks. The service provides HTTP endpoints for querying broker information and consumer group status, allowing external tools to poll for system health and performance m
Calculates consumer lag by tracking committed offsets over a specific time interval to detect processing delays.