Издание kafkalet 0.1, десктопен клиент за Apache Kafka

Публикувано е издание на kafkalet 0.1, десктопен графичен клиент за работа с Apache Kafka. Приложението се предоставя като самостоятелен бинарен файл с размер около 15 MB, не изисква инсталиране на JVM, Docker или стартиране на сървърни компоненти. Кодът на проекта е написан на Go и TypeScript и се разпространява под MIT лиценз. Компилациите са подготвени за macOS (Intel и Apple Silicon), Windows и Linux.

В отличие от съществуващите уеб-ориентирани инструменти, като Kafka UI и AKHQ, които изискват разгръщане на сървърен процес в Docker, kafkalet работи като обикновено десктопно приложение — подобно на DBeaver или DataGrip за бази данни. Единственият десктопен Kafka клиент до момента е бил Offset Explorer (по-рано Kafka Tool), написан на Java и отдавна не обновяван. Приложението kafkalet е построено на базата на фреймворка Wails v2, който обединява Go бекенд с уеб интерфейс на React 18, TypeScript и shadcn/ui в един нативен бинарен файл. За взаимодействие с Kafka се използва библиотеката franz-go, реализирана на чист Go без зависимости от librdkafka и CGO.

Основни функции:

• Система за профили за управление на множество среди (production, staging, dev). Всеки брокер в профила може да има няколко именувани акаунта с възможност за бързо превключване. Паролите и токените се съхраняват единствено в системното хранилище на секрети на ОС (macOS Keychain, Windows Credential Manager, libsecret на Linux) и не се записват в конфигурационни файлове.
• Режимът Observer — четене на съобщения от тема без свързване с consumer група, без комит на смещения и без странични ефекти върху кластера. Отделният режим Consumer позволява свързване към групата и фиксиране на смещенията ръчно.
• Навигация по времето (seek to timestamp) — преминаване към съобщения по посочена дата и час без необходимост от ръчно изчисляване на смещения. Подкрепа на методи за автентикация: SASL PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, OAUTHBEARER (статичен токен и flow с клиентски креденциали), TLS с проверка на сертификата сървър, mTLS (взаимна автентикация с сертификати).
• Потоково преглеждане на съобщения с regex филтриране по ключове и стойности в реално време. Подкрепя се едновременно наблюдение на няколко теми в отделни раздели. Виртуализацията на списъка позволява показване на над 50 000 съобщения без загуба на производителност.
• Управление на теми: създаване, изтриване, промяна на конфигурационни параметри, преглед на раздели, лидери и набор от синхронизирани реплики (ISR).
• Управление на потребителски групи: преглед на закъснението (lag) по раздели, нулиране на офсетите на earliest, latest или конкретна времева маркировка, преглед на участниците в групата (ID на клиента, хост, назначени теми), изтриване на групи.
• Изпращане на съобщения с посочване на ключ, стойност, заглавки и целеви раздел.
• Организация на темите: закрепване на често използвани теми, групиране в именувани папки, търсене с поддръжка на регулярни изрази и филтриране по минимален брой раздели.
• Експорт на буфера със съобщения в JSON или CSV формат.
• Интеграция с Confluent Schema Registry за автоматично декодиране на съобщения в Avro формат.
• Система от JavaScript плъгини за потребителско декодиране на съобщения (Protobuf, MessagePack и други формати).
• Импорт и експорт на настройки в JSON формат, включително профили, групи теми и закрепени теми.

Източник: opennet.ru