Opublikowano wersję kafkalet 0.1, aplikacji klienckiej opartej na grafice do pracy z Apache Kafka. Aplikacja dostarczana jest jako samodzielny plik binarny o wielkości około 15 MB, nie wymaga instalacji JVM, Dockera ani uruchamiania komponentów serwerowych. Kod projektu został napisany w Go i TypeScript i jest rozpowszechniany na licencji MIT. Kompilacje przygotowane są dla macOS (Intel i Apple Silicon), Windows oraz Linux.
W przeciwieństwie do istniejących narzędzi webowych, takich jak Kafka UI i AKHQ, które wymagają uruchomienia procesu serwerowego w Dockerze, kafkalet działa jak typowa aplikacja desktopowa — podobnie jak DBeaver czy DataGrip dla baz danych. Jedynym desktopowym klientem Kafka do tej pory był Offset Explorer (wcześniej Kafka Tool), napisany w Javie, który od dłuższego czasu nie był aktualizowany. Aplikacja kafkalet oparta jest na frameworku Wails v2, łączącym backend w Go z interfejsem webowym opartym na React 18, TypeScript i shadcn/ui w jeden natywny plik binarny. Do interakcji z Kafka używana jest biblioteka franz-go, napisana w czystym Go, bez zależności od librdkafka i CGO.
Podstawowe funkcje:
- System profili do zarządzania wieloma środowiskami (production, staging, dev). Każdy broker w profilu może mieć kilka nazwanych kont z możliwością szybkiego przełączania. Hasła i tokeny przechowywane są wyłącznie w systemowym magazynie sekretów OS (macOS Keychain, Windows Credential Manager, libsecret na Linuxie) i nie są zapisywane w plikach konfiguracyjnych.
- Tryb Observer — odczyt wiadomości z tematu bez podłączenia do grupy konsumentów, bez zatwierdzania offsetów i bez efektów ubocznych na klastrze. Osobny tryb Consumer pozwala na dołączenie do grupy i ręczne zatwierdzanie offsetów.
- Nawigacja czasowa (przejdź do znacznika czasu) — przechodzenie do wiadomości na podstawie podanej daty i czasu bez konieczności ręcznego obliczania offsetów. Obsługuje metody uwierzytelniania: SASL PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, OAUTHBEARER (statyczny token i przepływ danych poświadczeń klienta), TLS z weryfikacją certyfikatu serwera, mTLS (wzajemne uwierzytelnianie za pomocą certyfikatów).
- Przeglądanie strumieniowe wiadomości z filtracją regex po kluczach i wartościach w czasie rzeczywistym. Obsługuje jednoczesne monitorowanie wielu tematów w oddzielnych zakładkach. Wirtualizacja listy umożliwia wyświetlanie ponad 50 000 wiadomości bez obniżania wydajności.
- Zarządzanie tematami: tworzenie, usuwanie, zmiana parametrów konfiguracyjnych, przeglądanie sekcji, liderów i zestawu synchronizowanych replik (ISR).
- Zarządzanie grupami konsumentów: przegląd opóźnień (lag) według sekcji, resetowanie przesunięć do earliest, latest lub konkretnej znacznik czasowego, przegląd uczestników grupy (ID klienta, host, przypisane tematy), usuwanie grup.
- Wysyłanie wiadomości z określonym kluczem, wartością, nagłówkami i docelową sekcją.
- Organizacja tematów: przypinanie często używanych tematów, grupowanie w nazwane foldery, wyszukiwanie z obsługą wyrażeń regularnych i filtrowaniem według minimalnej liczby sekcji.
- Eksport bufora wiadomości w formacie JSON lub CSV.
- Integracja z Confluent Schema Registry w celu automatycznego dekodowania wiadomości w formacie Avro.
- System wtyczek JavaScript do niestandardowego dekodowania wiadomości (Protobuf, MessagePack i inne formaty).
- Import i eksport ustawień w formacie JSON, w tym profile, grupy tematów i przypięte tematy.
Źródło: opennet.ru
