Kafka Web UI Tool

Formål & Brugerintention: Dette værktøj giver browserbaseret Kafka-klyngeadministration til udviklere, driftspersonale og dataingeniører. Det løser problemet med håndtering af emner, forbrugergrupper og grundlæggende dataflow uden lokal værktøj. Anvendelsestilfælde inkluderer validering af emnekonfigurationer, inspektion af lagg og levering af emner i staging- eller produktionsmiljøer, når synlighed og kontrol over flere klustre er nødvendig. Brugergrupperne er platformteams, SRE og dataingeniører, der kræver operationel indsigt og sikker håndtering af emner i distribuerede streaming-pipelines.
Kerne-logik & funktioner: Obligatoriske funktioner omfatter cluster-opdagelse via bootstrap-servers, metadataindsamling for brokers, emner og grupper samt emne-livscyklus-operationer (opret, ændre, slette) med grundlæggende konfig-styring. Valgfri/avanserede funktioner omfatter ACL-understøttede operationer, multi-klynge-aggregering, per-partition lag-analyse, end-to-end dataflow-test og JSON-eksport af resultater. Værktøjet bruger Kafka AdminClient-API’er, henter end offsets og beregner lag som end_offset - committed_offset per partition og aggregerer per emne. Validering følger Kafka-navngivningsregler og respekterer cluster RBAC, når legitimationsoplysninger er tilvejebragt.
Indtastninger & Uddata: Indtastninger inkluderer bootstrap_servers (streng), security_protocol (streng), sasl_mechanisms (streng, valgfri), sasl_username (streng), sasl_password (streng, valgfri), topic_name (streng), partitions (heltal), replication_factor (heltal), operation (streng), config_overrides (nøgle/værdi kort). Uddata inkluderer topic-liste, consumer_groups, lag_metrics, topic_configs og eksportérbart JSON. Uddata præsenteres som strukturerede data per topic og per gruppe, med numeriske felter i standardenheder (offsets, lag, throughput).
Algoritmer & Beregninger: Bruger AdminClient til metadataindsamling; beregner lag per partition som high_watermark - committed_offset; aggregerer til topic-niveau med maks lag og gennemsnitslag; anvender end_offsets() for hver partition; udfører på anmodning en lille testproducer/consumer for at validere flytningen.
Fejl & Kanttilfælde: Håndterer ugyldige bootstrap_servers, autentificeringsfejl, manglende emner, ikke-understøttede operationer, utilstrækkelige rettigheder; håndterer forskelle i klusterets version; rapporterer fejl i struktureret format uden bivirkninger.
Branchering/Region & Lokalisering: Enheder er tællinger og offsets; tider i ms; understøtter klustre på tværs af regioner; tidsstempler i standardformat; ingen valuta; lokalisering fokuserer på talformatering og tidszoner hvor understøttet.