Kafka Web UI Tool

Propósito e intención del usuario: Esta herramienta ofrece gestión de clústeres de Kafka basada en navegador para desarrolladores, operadores e ingenieros de datos. Resuelve el problema de administrar topics, grupos de consumidores y flujos de datos básicos sin herramientas locales. Casos de uso incluyen validación de configuraciones de topics, inspección de lag de consumidores y provisión de topics en entornos de staging o producción cuando se requiere visibilidad y control sobre múltiples clusters. Los usuarios previstos son equipos de plataforma, SRE e ingenieros de datos que requieren visión operativa y gestión segura de topics en pipelines de streaming distribuidos.
Lógica central & características: Las funciones obligatorias incluyen descubrimiento de cluster vía bootstrap servers, recuperación de metadatos para brokers, topics y grupos, y operaciones del ciclo de vida de topics (crear, modificar, eliminar) con gestión básica de configuraciones. Funciones opcionales/avanzadas incluyen operaciones basadas en ACL, agregación multi-cluster, análisis de lag por partición, pruebas de flujo end-to-end y exportación JSON de resultados. La herramienta utiliza Kafka AdminClient-APIs, recoge offsets finales y calcula lag como end_offset - committed_offset por partición, agregando por topic. Aplica validación conforme a normas de nomenclatura de Kafka y respeta RBAC si se proporcionan credenciales.
Entradas y salidas: Entradas: bootstrap_servers (cadena), security_protocol (cadena), sasl_mechanisms (cadena, opcional), sasl_username (cadena), sasl_password (cadena, opcional), topic_name (cadena), partitions (entero), replication_factor (entero), operation (cadena), config_overrides (map clave-valor). Salidas: lista de topics, consumer_groups, lag_metrics, topic_configs y JSON exportable. Las salidas se muestran como datos estructurados por topic y por grupo, con campos numéricos en unidades estándar (offsets, lag, throughput).
Algoritmos & Cálculos: Utiliza AdminClient para obtener metadatos; calcula lag por partición como high_watermark - committed_offset; agrega a nivel de topic con lag máximo y lag medio; usa end_offsets() por partición; realiza, si se solicita, una pequeña prueba de flujo con productor/ consumidor para validar el recorrido.
Errores y casos límite: Maneja bootstrap_servers inválidos, fallos de autenticación, nombres de topics ausentes, operaciones no soportadas y permisos insuficientes; gestiona diferencias entre versiones del clúster; reporta errores de forma estructurada sin efectos secundarios.
Industria/Región & Localización: Unidades son conteos y offsets; tiempos en ms; soporta clústeres en distintas regiones; sellos de tiempo en formato estándar; sin moneda; localización centrada en formato numérico y zonas horarias donde sea compatible.