ППредставлен публике публичный инициатива kafkalet — десктопный заказчик для Apache Kafka

ППредставлен публике открытый проект kafkalet. Это десктопный графический клиент для для работы с Apache Kafka. Решение поставляется в виде самов достаточной степениго бинарного файла размером около 15 МБ. Проект не требует установки JVM, Docker или запуска серверных компонентов. Исходный код решения написан на Go и TypeScript и распространяется под лицензией MIT.

Сборки опубликованы для macOS (Intel и Apple Silicon), Windows и Linux.

По информации OpenNET, в отличие от существующих веб‑ориентированных инструментов, таких как Kafka пользовательский интерфейс и 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.

Основные возможности kafkalet:

• система профилей для управления несколькими окружениями (production, staging, dev). Каждый брокер в профиле может иметь несколько именованных учётных записей с возможностью быстрого переключения. Пароли и токены хранятся исключительно в системном память секретов ОС (macOS Keychain, Windows Credential Manager, libsecret на Linux) и не записываются в конфигурационные файлы;

• режим Observer — чтение сообщений из топика без подключения к consumer group, без коммита смещений и без побочных эффектов на кластере. Отдельный режим Consumer позволяет подключиться к группе и зафиксировать смещения вручную;

• навигация по времени (seek to timestamp) — переход к сообщениям по указанной дате и времени без необходимости вычислять смещения вручную. Поддержка методов аутентификации: SASL PLAIN, SCRAM‑SHA-256, SCRAM‑SHA-512, OAUTHBEARER (статический токен и client credentials flow), TLS с проверкой сертификата сервера, mTLS (взаимная аутентификация по сертификатам);

• потоковый просмотр сообщений с regex‑фильтрацией по ключам и значениям в реальном времени. Поддерживается одновременное наблюдение за несколькими топиками в отдельных вкладках. Виртуализация списка даёт возможность отображать более 50 000 сообщений без снижения производительности;

• управление топиками: создание, исключение, модификация конфигурационных параметров, просмотр разделов, лидеров и набора синхронизированных реплик (ISR);

  

• управление consumer groups: просмотр отставания (lag) по разделам, сброс смещений на earliest, latest или конкретную временную метку, просмотр участников группы (client ID, сервер, назначенные топики), исключение групп;

• отправка сообщений с указанием ключа, значения, заголовков и целевого раздела;

  

• организация топиков: закрепление часто используемых топиков, группировка в именованные папки, поиск с поддержкой регулярных выражений и фильтрацией по минимальному числу разделов;

• экспорт буфера сообщений в формате JSON или CSV;

• встраивание с Confluent Schema Registry для автоматического декодирования сообщений в формате Avro;

• платформа JavaScript‑плагинов для пользовательского декодирования сообщений (Protobuf, MessagePack и другие форматы);

• импорт и экспорт настроек в формате JSON, в том числе профили, группы топиков и закреплённые топики.