A fost publicată versiunea kafkalet 0.1, un client grafic desktop pentru lucrul cu Apache Kafka. Aplicația este livrată sub formă de fișier binar autonom cu o dimensiune de aproximativ 15 MB, fără a necesita instalarea JVM, Docker sau rularea componentelor server. Codul proiectului este scris în Go și TypeScript și este distribuit sub licența MIT. Construirile sunt pregătite pentru macOS (Intel și Apple Silicon), Windows și Linux.
Spre deosebire de instrumentele existente orientate pe web, cum ar fi Kafka UI și AKHQ, care necesită desfășurarea unui proces server în Docker, kafkalet funcționează ca o aplicație desktop obișnuită — similar cu DBeaver sau DataGrip pentru baze de date. Cel mai recent client Kafka desktop a fost Offset Explorer (anterior Kafka Tool), scris în Java și care nu a mai fost actualizat de mult timp. Aplicația kafkalet este construită pe baza framework-ului Wails v2, care unește backend-ul Go cu interfața web bazată pe React 18, TypeScript și shadcn/ui într-un singur fișier binar nativ. Pentru interacțiunea cu Kafka este utilizată biblioteca franz-go, implementată în Go curat fără dependență de librdkafka și CGO.
Funcționalități principale:
- Sistemul de profiluri pentru gestionarea mai multor medii (production, staging, dev). Fiecare broker din profil poate avea mai multe conturi numite cu posibilitatea de a comuta rapid între ele. Parolele și token-urile sunt stocate exclusiv în magazinul de secrete al sistemului de operare (macOS Keychain, Windows Credential Manager, libsecret pe Linux) și nu sunt scrise în fișierele de configurare.
- Modul Observer — citirea mesajelor dintr-un topic fără a se conecta la un grup de consumatori, fără a confirma deplasările și fără efecte secundare asupra cluster-ului. Un mod distinct de Consumer permite conectarea la grup și confirmarea deplasării manual.
- Navigarea în timp (căutare după timestamp) — trecerea la mesaje pe baza datei și orei specificate fără a necesita calcularea deplasărilor manual. Suport pentru metode de autentificare: SASL PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, OAUTHBEARER (token static și flux de credite client), TLS cu verificarea certificatului. server, mTLS (autentificare sufletească prin certificate).
- Vizualizarea în flux a mesajelor cu filtrare regex pe chei și valori în timp real. Se suportă monitorizarea simultană a mai multor topicuri în tab-uri separate. Virtualizarea listei permite afișarea a peste 50.000 de mesaje fără a reduce performanța.
- Gestionarea topicurilor: crearea, ștergerea, modificarea parametrilor de configurare, vizualizarea secțiunilor, liderilor și setului de replici sincronizate (ISR).
- Gestionarea grupurilor de consumatori: vizualizarea întârzierii (lag) pe secțiuni, resetarea offset-urilor la earliest, latest sau la un timestamp specific, vizualizarea participanților la grup (client ID, host, topic-uri alocate), ștergerea grupurilor.
- Trimiterea mesajelor cu specificarea cheii, valorii, antetelor și a secțiunii țintă.
- Organizarea topicurilor: fixarea topicurilor utilizate frecvent, gruparea în foldere desemnate, căutarea cu suport pentru expresii regulate și filtrarea după numărul minim de secțiuni.
- Exportarea bufferului de mesaje în format JSON sau CSV.
- Integrarea cu Confluent Schema Registry pentru decodificarea automată a mesajelor în format Avro.
- Sistem de pluginuri JavaScript pentru decodificarea personalizată a mesajelor (Protobuf, MessagePack și alte formate).
- Importarea și exportarea setărilor în format JSON, inclusiv profiluri, grupuri de topicuri și topicuri fixate.
Sursa: opennet.ro
