1 dépôt
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 est un service de monitoring et d'alerte pour les clusters Kafka. Il suit le lag des groupes de consommateurs en évaluant les offsets validés et en identifiant l'écart entre les messages produits et consommés. Le système calcule les délais de traitement en utilisant une évaluation d'offset par fenêtre glissante et surveille l'état de santé global du cluster. Lorsque les conditions des groupes de consommateurs atteignent des seuils prédéfinis, il déclenche des notifications vers des services externes via email ou webhooks. Le service fournit des endpoints HTTP pour interroger les informations des brokers et le statut des groupes de consommateurs, permettant aux outils externes d'interroger l'état de santé du système et les métriques de performance.
Calculates consumer lag by tracking committed offsets over a specific time interval to detect processing delays.