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. تتتبع تأخر مجموعة المستهلكين (consumer group lag) من خلال تقييم الإزاحات الملتزم بها وتحديد الفجوة بين الرسائل المنتجة والمستهلكة. يحسب النظام تأخيرات المعالجة باستخدام تقييم إزاحة النافذة المنزلقة ويراقب صحة المجموعة بشكل عام. عندما تستوفي ظروف مجموعة المستهلكين عتبات محددة مسبقاً، فإنه يطلق إشعارات للخدمات الخارجية عبر البريد الإلكتروني أو webhooks. توفر الخدمة نقاط نهاية HTTP للاستعلام عن معلومات الوسيط وحالة مجموعة المستهلكين، مما يسمح للأدوات الخارجية باستطلاع صحة النظام ومقاييس الأداء.
Calculates consumer lag by tracking committed offsets over a specific time interval to detect processing delays.