Kafka Web UI Tool

Doel en Gebruikersintentie: Dit gereedschap biedt browser-gebaseerde Kafka-clusterbeheer voor ontwikkelaars, operators en data engineers. Het lost het probleem op van het beheren van topics, consumer groups en basisstroomgegevens zonder lokale tooling. Gebruiksscenario’s zijn onder meer validatie van topic-configuraties, inspectie van consumer lag en provisioning van topics in staging- of productieomgevingen wanneer zichtbaarheid en controle over meerdere clusters nodig zijn. De beoogde gebruikers zijn platformteams, SRE’s en data engineers die operationele inzichten en veilige topic-beheer in gedistribueerde streaming-pijplijnen vereisen.
Kernlogica & Functies: Verplicht: cluster-detectie via bootstrap-servers, metadata-inkoop voor brokers, topics en consumer groups, topic lifecycle-operaties (create, alter, delete) met basisconfiguratie. Optioneel/gevorderd: ACL-ondersteunde operaties, multi-cluster-aggregatie, per-partitie lag-analyse, end-to-end dataflow-testen en JSON-export van resultaten. Het tool gebruikt Kafka AdminClient-API’s, haalt end offsets op en berekent lag als end_offset - committed_offset per partitie, geaggregeerd per topic. Validatie volgens Kafka-namenregels en respecteert RBAC als inloggegevens aanwezig zijn.
In- en Uitgangen: Invoer: bootstrap_servers (string), security_protocol (string), sasl_mechanisms (string, optioneel), sasl_username (string), sasl_password (string, optioneel), topic_name (string), partitions (integer), replication_factor (integer), operation (string), config_overrides (key/value map). Uitvoer: topics-lijst, consumer_groups, lag_metrics, topic_configs en exporteerbaar JSON. Uitvoer is per topic en groep gestructureerd, met numerieke velden in standaardseenheden (offsets, lag, throughput).
Algoritmen & Berekeningen: Gebruikt AdminClient om metadata op te halen; berekent lag per partitie als high_watermark - committed_offset; aggregeert per topic met max-lag en gemiddelde-lag; gebruikt end_offsets() per partitie; voert optioneel een kleine testproducer/consumer uit om de dataflow te valideren.
Fouten & Randgevallen: Verwerkt ongeldige bootstrap_servers, authenticatiefouten, ontbrekende topics, niet-ondersteunde operaties, onvoldoende rechten; houdt rekening met clusterversies; rapporteert fouten gestructureerd zonder bijwerkingen.
Industrie/Regio & Lokalisatie: Eenheden zijn tellingen en offsets; tijden in ms; ondersteunt clusters over regio’s; tijdstempels in standaardformaat; geen valuta; lokalisatie gericht op getalnotatie en tijdzones waar ondersteund.