OSCHINA-MIRROR/dushixiang-kafka-map

Кафка-мэп: визуализация и управление кластерами Apache Kafka

Добавьте крылья к программированию и установите навигацию в Kafka.

Введение

Kafka-мэп — это инструмент визуализации для Apache Kafka, разработанный с использованием Java 17 и React.

Поддерживаемые функции:

Управление несколькими кластерами.
Мониторинг состояния кластера (количество разделов, количество реплик, размер хранилища, смещение).
Создание, удаление и расширение тем (для удаления необходимо настроить delete.topic.enable = true).
Мониторинг статуса брокера.
Просмотр и удаление групп потребителей.
Сброс смещения.
Просмотр данных по темам и поиск (поддержка отображения строк и JSON).
Отправка сообщений в тему.
Задержка сообщений (поддерживает 18 уровней отложенных сообщений).

Скриншоты

Импорт кластера

Добавление кластера.

Кластеры

Управление кластерами.

Брокеры

Брокеры.

Темы

Управление темами.

Группы потребителей

Группы потребителей.

Подписка группы потребителей

Подробности о группе потребителей.

Раздел темы

Детали раздела темы.

Брокеров темы

Информация о брокерах темы.

Потребительские группы темы

Потребительские группы темы.

Сброс смещения потребительских групп темы

Сброс смещения потребительских групп.

Конфигурации темы

Конфигурации темы.

Создание сообщения

Создание сообщения.

Потребление сообщения

Потребление сообщения.

Отложенное сообщение

Отложенное сообщение.

Отказ от ответственности

Разработчикам, желающим использовать kafka-мэп в корпоративной сети, рекомендуется получить одобрение от своих администраторов или руководства перед использованием инструмента. Скачивая, используя или распространяя kafka-мэп, вы соглашаетесь с условиями лицензии. Гарантии и ответственность не предоставляются.

Требования

Java 17 или выше.
Apache Kafka 1.1.0 или выше.

Установка через Docker

Конец.

Параметр	Описание
DEFAULT_USERNAME	Имя пользователя для начального входа
DEFAULT_PASSWORD	Пароль для начального входа

docker run -d \
    -p 8080:8080 \
    -v /opt/kafka-map/data:/usr/local/kafka-map/data \
    -e DEFAULT_USERNAME=admin \
    -e DEFAULT_PASSWORD=admin \
    --name kafka-map \
    --restart always dushixiang/kafka-map:latest

Установка без Docker

Скачайте:

wget https://github.com/dushixiang/kafka-map/releases/latest/download/kafka-map.tgz

Распакуйте:

tar -zxvf kafka-map.tgz -C /usr/local/

Запуск на переднем плане

# каталог kafka-мэп
cd /usr/local/kafka-map
# Измените конфигурацию в соответствии со своими потребностями
vi application.yml
# запустите
java -jar kafka-map.jar

Запуск как системный сервис

cat <<EOF >> /etc/systemd/system/kafka-map.service
[Unit]
Description=сервис kafka map
After=network.target

[Service]
WorkingDirectory=/usr/local/kafka-map
ExecStart=/usr/bin/java -jar /usr/local/kafka-map/kafka-map.jar
Restart=on-failure

[Install]
WantedBy=multi-user.target
EOF

Перезагрузите системный сервис, настройте автоматический запуск при загрузке, запустите сервис и проверьте статус:

systemctl daemon-reload
systemctl enable kafka-map
systemctl start kafka-map
systemctl status kafka-map

Использование

Затем используйте браузер для доступа к порту сервера 8080.

FAQ

Что делать, если я не хочу использовать порт 8080?

Добавьте --server.port=1234 в команду запуска, чтобы изменить порт на 1234.

# пример
java -jar kafka-map.jar --server.port=1234