1 repositorio
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 es un servicio de monitoreo y alerta para clusters de Kafka. Rastrea el lag de los grupos de consumidores evaluando los offsets confirmados e identificando la brecha entre los mensajes producidos y consumidos. El sistema calcula los retrasos de procesamiento utilizando una evaluación de offset de ventana deslizante y monitorea el estado general del cluster. Cuando las condiciones del grupo de consumidores cumplen umbrales predefinidos, activa notificaciones a servicios externos mediante correo electrónico o webhooks. El servicio proporciona endpoints HTTP para consultar información del broker y el estado del grupo de consumidores, permitiendo que herramientas externas consulten el estado del sistema y las métricas de rendimiento.
Calculates consumer lag by tracking committed offsets over a specific time interval to detect processing delays.