Издание на 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 позволява четене на съобщения от topic без свързване към consumer group, без комит на offset и без странични ефекти върху кластера. Отделен режим Consumer позволява свързване към групата и ръчно фиксиране на offset.
• Навигация по време (seek to timestamp) — преход към съобщения по указаната дата и час, без нужда от ръчно изчисляване на offsets. Подкрепа за методи на аутентификация: SASL PLAIN, SCRAM-SHA-256, SCRAM-SHA-512, OAUTHBEARER (статичен токен и flow с клиентски идентификационни данни), TLS с проверка на сертификата сървър, mTLS (взаимна аутентификация по сертификати).
• Потоково наблюдение на съобщения с regex филтриране по ключове и стойности в реално време. Поддържа се едновременно наблюдение на няколко topic-а в отделни табове. Виртуализацията на списъка позволява показване на над 50 000 съобщения без намаляване на производителността.
• Управление теми: създаване, изтриване, промяна на конфигурационни параметри, преглед на раздели, лидери и набор от синхронизирани реплики (ISR).
• Управление на групи консуматори: преглед на закъснения (lag) по раздели, нулиране на офсети на earliest, latest или конкретна времева отметка, преглед на участниците в групата (client ID, хост, назначени теми), изтриване на групи.
• Изпращане на съобщения с указване на ключ, стойност, заглавия и целеви раздел.
• Организиране на теми: закрепване на често използвани теми, групиране в именувани папки, търсене с помощта на регулярни изрази и филтриране по минимален брой раздели.
• Експорт на буфера на съобщения в формат JSON или CSV.
• Интеграция с Confluent Schema Registry за автоматично декодиране на съобщения в формат Avro.
• Система от JavaScript плъгини за потребителско декодиране на съобщения (Protobuf, MessagePack и други формати).
• Импорт и експорт на настройки в формат JSON, включително профили, групи теми и закрепени теми.

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