Megjelent a kafkalet 0.1, egy grafikus asztali kliens Apache Kafka használatához. Az alkalmazás önálló bináris fájlként érhető el, körülbelül 15 MB méretben, nem igényel JVM, Docker telepítést vagy szerverkomponensek indítását. A projekt kódja Go és TypeScript nyelven íródott, és MIT licenc alatt érhető el. A build csomagok macOS-re (Intel és Apple Silicon), Windows-ra és Linux-ra készültek.
A meglévő webalapú eszközöktől, mint a Kafka UI és az AKHQ, amelyek szerverfolyamat Docker-ben való telepítését igénylik, eltérően a kafkalet hagyományos asztali alkalmazásként működik — hasonlóan a DBeaverhez vagy a DataGriphez adatbázisokhoz. Az egyedüli asztali Kafka kliens eddig az Offset Explorer (korábbi nevén Kafka Tool) volt, amely Java nyelven készült és régóta nem frissült. A kafkalet alkalmazás a Wails v2 keretrendszerre épül, amely a Go backendet egyesíti a React 18, TypeScript és shadcn/ui webes felhasználói felületével egy natív bináris fájlban. A Kafka-val való interakcióhoz a franz-go könyvtárat használja, amely tiszta Go nyelven készült, anélkül, hogy függne a librdkafka-tól vagy a CGO-tól.
Főbb funkciók:
- Profilkezelő rendszer, amely lehetővé teszi több környezet (production, staging, dev) kezelését. Minden broker a profilban több névvel ellátott fiókot tartalmazhat, amelyek között gyorsan lehet váltani. A jelszavak és tokenek kizárólag az operációs rendszer titkos tárolójában (macOS Keychain, Windows Credential Manager, libsecret Linuxon) kerülnek tárolásra, és nem kerülnek be a konfigurációs fájlokba.
- Megfigyelő mód — üzenetek olvasása a témáról anélkül, hogy csatlakozni kellene a consumer grouphoz, anélkül, hogy offseteket kellene elkötelezni, és anélkül, hogy mellékhatása lenne a klaszterre. A külön megfigyelő mód lehetővé teszi, hogy csatlakozzon egy csoporthoz és manuálisan rögzítse az offseteket.
- Időbeli navigáció (seek to timestamp) — átugrás az üzenetekhez a megadott dátum és idő alapján, anélkül, hogy manuálisan kellene kiszámítani az offseteket. Támogatott azonosítási módszerek: SASL PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, OAUTHBEARER (statikus token és client credentials flow), TLS tanúsítványellenőrzéssel. a szerver, mTLS (tanúsítványokkal végzett kölcsönös azonosítás).
- Üzenetek folyamatos megtekintése regex-szűréssel kulcsok és értékek alapján valós időben. Támogatja több téma egyidejű megfigyelését különböző fülekben. A lista virtualizációja lehetővé teszi több mint 50 000 üzenet megjelenítését teljesítménycsökkenés nélkül.
- Témák kezelése: konfigurációs paraméterek létrehozása, törlése, módosítása, szekciók, vezetők és szinkronizált replikák (ISR) megtekintése.
- Fogyasztói csoportok kezelése: részlegenkénti késést (lag) megtekintése, eltolások visszaállítása earliest, latest vagy konkrét időbélyegre, a csoport tagjainak (client ID, gazda, hozzárendelt témák) megtekintése, csoportok törlése.
- Üzenetek küldése kulcs, érték, fejlécek és célzott részleg megadásával.
- Témák szervezése: gyakran használt témák rögzítése, névre keresztelt mappákba való csoportosítás, reguláris kifejezések támogatásával történő keresés és minimális rész szám szerinti szűrés.
- Üzenettároló exportálása JSON vagy CSV formátumban.
- Integráció a Confluent Schema Registry-vel az Avro formátumban lévő üzenetek automatikus dekódolásához.
- JavaScript bővítményrendszer a felhasználói üzenetdekódoláshoz (Protobuf, MessagePack és más formátumok).
- Beállítások importálása és exportálása JSON formátumban, beleértve a profilokat, témacsoportokat és rögzített témákat.
Forrás: opennet.ru
