Работа с Kafka UI

Интерфейс Kafka UI используется для отслеживания длительных операций (например, копирование и удаление объектов или генерация отчетов).

Чтобы открыть интерфейс Kafka, нужно перейти по следующему URL адресу, указав вручную IP вашего хоста: http://<IP_вашей_хост-машины>:9999

Авторизация не требуется. Кластер отображается под именем переменной KAFKA_UI_CLUSTER_NAME из файла .env (см. Рисунок 1).

Рисунок 1. Интерфейс кластера

В данном примере имя кластера — «ALPHA».

Здесь отображаются все очереди Kafka. Названия топиков (server_actions, ui_actions) включают имя базы данных и номер ветки, на которых запущены эти очереди (см. Рисунок 2):

Рисунок 2. Вкладка «Topics»

Чтобы увидеть задачи, поставленные в очередь на конкретной ветке, выберите её в списке и перейдите на вкладку Messages (см. Рисунок 3):

Рисунок 3. Просмотр задач в очереди

Используется для проверки выполнения задач (например, завершилась ли генерация отчета) (см. Рисунок 4).

Рисунок 4. Вкладка «Consumers»

Анализ очереди можно провести, перейдя на нужную ветку. Если показатель Consumer Lag растет — отчеты и действия копятся в очереди, не успевая обрабатываться.