ניטור נושאי Kafka

הכלי מספק ראייה בזמן אמת על נושאי Kafka ברחבי אשכולות. הוא אוסף throughput לכל נושא, lag של צרכנים, מצב partitions ובר stuck של ברוקר, כדי לסייע למפעילים ולמפתחים להעריך צינורות streaming. מקורות המידע כוללים מדדים מהברוקר באמצעות JMX או נקודות מדידה וסטטיסטיקות בצד הלקוח של producers/consumers, משולבות בתצוגות זמן-סדר עם השהיה קבועה. המסננים על בסיס cluster, topic וקבוצת צרכנים מאפשרים טווח מדויק. באופן כללי, הוא מחשב throughput לכל topic (הודעות לשנייה), lag לפי קבוצות צריכה ותקינות partitions, והנתונים מסוכמים לפי topic או cluster. הוא משתמש בחלונות נעים (למשל 1m, 5m) ותומך בהשוואות היסטוריות לזיהוי מגמות. זיהוי אנומליות פשוט מסמן פיקים או deviations מהקו הבסיס; אינדיקטורים על בסיס פרסנטיל מפחיתים רעש. בהגדרות מרובות-אשכולות, תאריכי זמן ו-id-ים של cluster מובנים. הערך הוא במאמץ תצורה נמוך, ערכי ברירת מחדל הגיוניים ותצואות מובנות שמתחברות למערכת אירועים. תכונות: איסוף מדדים בזמן אמת, לוחות per-topic, ניתוח lag, בריאות partitions, גבולות התראה וייצוא CSV/JSON. מקרים: ניטור ייצור, תכנון קיבולת, ניתוח אירועים וביקורות לאחר-אירוע; מתאים למהנדסי נתונים, SREteam וצוותי פלטפורמה שמנהלים pipelines streaming.