1 Repo
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 ist ein Überwachungs- und Alarmierungsdienst für Kafka-Cluster. Er verfolgt den Consumer-Group-Lag durch Auswertung der committeten Offsets und Identifizierung der Lücke zwischen produzierten und konsumierten Nachrichten. Das System berechnet Verarbeitungsverzögerungen unter Verwendung einer Sliding-Window-Offset-Auswertung und überwacht die allgemeine Cluster-Gesundheit. Wenn die Bedingungen der Consumer-Gruppe vordefinierte Schwellenwerte erreichen, löst es Benachrichtigungen an externe Dienste via E-Mail oder Webhooks aus. Der Dienst bietet HTTP-Endpunkte für die Abfrage von Broker-Informationen und dem Status der Consumer-Gruppe, wodurch externe Tools den Systemzustand und Leistungsmetriken abfragen können.
Calculates consumer lag by tracking committed offsets over a specific time interval to detect processing delays.