Kafka Web UI Tool

Syfte & användarlimp: Detta verktyg erbjuder webbläsarbaserad Kafka-klusterhantering för utvecklare, driftansvariga och dataingenjörer. Det löser problemet med att administrera topics, konsumentgrupper och grundläggande dataflöden utan lokal verktyg. Användningsfall inkluderar validering av topic-konfigurationer, inspektion av lagg för konsumenter och provisioning av topics i staging- eller Produktionsmiljöer när synlighet och kontroll över flera kluster behövs. Användare är plattformsteam, SRE och dataingenjörer som kräver operativ insikt och säker topic-hantering i distribuerade stream-pipelines.
Kärnlógica & Funktioner: Obligatoriska funktioner innefattar klusterupptäckt via bootstrap-servrar, metadatahämtning för brokers, topics och grupper, samt topic-lifecycle-operationer ( skapa, ändra, ta bort ) med grundläggande config-hantering. Valfria/förvaldade funktioner inkluderar ACL-stödda operationer, multi-kluster-aggregation, per-partition lagg-analys, end-to-end dataflödestester och JSON-export av resultat. Verktyget använder Kafka AdminClient-API:er, hämtar slutoffsets och beräknar lagg som end_offset - committed_offset per partition och aggregerar per topic. Validering följer Kafka-namngivningsregler och respekterar cluster RBAC när uppgifterna lämnas.
In- och Utdata: Inmatningar inkluderar bootstrap_servers (sträng), security_protocol (sträng), sasl_mechanisms (sträng, valfritt), sasl_username (sträng), sasl_password (sträng, valfritt), topic_name (sträng), partitions (heltal), replication_factor (heltal), operation (sträng), config_overrides (nyckel/värde-karta). Utdata inkluderar topics-lista, consumer_groups, lag_metrics, topic_configs och exportbart JSON. Utdata presenteras som strukturerade data per topic och per grupp, med numeriska fält i standardenheter (offsets, lag, throughput).
Algoritmer & Beräkningar: Använder AdminClient för att samla metadata; beräknar lag per partition som high_watermark - committed_offset; aggregerar till topic-nivå med max lag och genomsnittligt lagg; använder end_offsets() per partition; kör vid begäran ett litet testproducent/consumidor för att validera flödet.
Fel & Randfall: Hanterar ogiltiga bootstrap_servers, autentiseringsfel, saknade topics, op-supported operationer, behörighetsproblem; hanterar skillnader i klusterversion; rapporterar fel i strukturerat format utan bieffekter.
Bransch/Region & Lokalisering: Enheter är räkningar och offsetar; tider i ms; stödjer kluster över regioner; tidsstämplar i standardformat; ingen valuta; lokalisering fokuserar på talformat och tidszoner där stöd finns.