Kafka Web UI Tool

الغرض ونية المستخدم: توفر هذه الأداة إدارة تجمع Kafka قائمة على المتصفح للمطورين والفرق التشغيلية ومهندسي البيانات. تحل مشكلة إدارة المواضيع ومجموعات المستهلكين وتدفقات البيانات الأساسية بدون أدوات محلية. حالات الاستخدام تشمل التحقق من إعدادات المواضيع، فحص lag المستهلكين وتوفير المواضيع في بيئات الـ staging أو الإنتاج عند الحاجة لرؤية وتحكم عبر عدة تجمعات. المستخدمون المستهدفون هم فرق المنصة، SRE ومهندسو البيانات الذين يحتاجون إلى رؤية تشغيلية وإدارة آمنة للمواضيع في خطوط تدفق البيانات الموزعة.
المنطق الأساسي والميزات: الميزات المطلوبة تشمل الاكتشاف التجميعي عبر خادم التمهيد bootstrap، واستخراج البيانات الوصفية للوسطاء، المواضيع والمجموعات، وعمليات دورة حياة المواضيع (إنشاء، تعديل، حذف) مع إدارة تكوينات أساسية. الميزات الاختيارية/المتقدمة تشمل عمليات متوافقة مع ACL، تجميع متعدد التجمعات، تحليل lag حسب الجزء، اختبارات تدفق من الطرف إلى الطرف وتصدير JSON للنتائج. يستخدم الأداة Kafka AdminClient، يستعيد الإزاحات النهائية ويحسب Lag كـ end_offset - committed_offset لكل جزء، ويجمع حسب الموضوع. يطبق تحققاً وفقاً لقواعد تسمية Kafka ويحترم RBAC عند توفير بيانات الاعتماد.
المدخلات/المخرجات: المدخلات تشمل bootstrap_servers (سلسلة)، security_protocol (سلسلة)، sasl_mechanisms (سلسلة، اختياري)، sasl_username (سلسلة)، sasl_password (سلسلة، اختياري)، topic_name (سلسلة)، partitions (عدد صحيح)، replication_factor (عدد صحيح)، operation (سلسلة)، config_overrides (خريطة مفتاح-قيمة). المخرجات تشمل قائمة المواضيع، مجموعات المستهلكين، lag_metrics، topic_configs وJSON قابل للتصدير. يتم عرض المخرجات كبيانات منظمة حسب الموضوع والمجموعة، مع حقول رقمية بوحدات قياسية (Offsets، Lag، Throughput).
الخوارزميات والحسابات: يستخدم AdminClient لجمع البيانات الوصفية؛ يحسب Lag لكل جزء كـ high_watermark - committed_offset؛ يجمع على مستوى الموضوع مع Lag أقصى ومتوسط Lag؛ يستخدم end_offsets() لكل جزء؛ ينفذ، عند الطلب، اختبار تدفق بسيط بمنتج/مستهلك للتحقق من المسار.
الأخطاء وحالات الحافة: يعالج عناوين bootstrap غير الصحيحة، فشل المصادقة، أسماء المواضيع المفقودة، عمليات غير مدعومة، صلاحيات غير كافية؛ يأخذ في الحسبان اختلافات إصدار العناقيد؛ يبلغ عن الأخطاء بشكل مُنظَّم دون تأثيرات جانبية.
الصناعة/المنطقة والتعريب: الوحدات هي عدادات والإزاحات؛ الأزمنة بوحدات ms؛ يدعم العناقيد في مناطق مختلفة؛ طوابع زمن بتنسيق قياسي؛ لا عملة؛ التعريب يركز على تنسيق الأعداد ومناطق التوقيت حيثما كان مدعومًا.