Работа с Kafka UI

Kafka UI используется для просмотра сообщений и отслеживания обновлений в веб-интерфейсе в реальном времени

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

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

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

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

В разделе Topics (см. Рисунок 2) отображаются все Kafka-топики (события), которые используются для:

• обновления данных в интерфейсе.
• отображения пользовательских событий.
• синхронизации состояния UI.

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

Топики можно разделить на два вида:

• data_changes_ — топик для событий об изменении данных (создание, обновление, удаление).
• messages_ — топик для сообщений и уведомлений между сервисами.

Просмотр сообщений осуществляется в разделе Topics (внутри выбранного топика) на вкладке Messages (см. Рисунок 3).

Примеры событий, которые можно увидеть:

• изменение состояния элемента интерфейса.
• обновление данных в таблице.
• действия пользователя (click, update, refresh).

Чтобы посмотреть события:

1. Откройте нужный топик.
2. Перейдите во вкладку Messages.
3. Просмотрите JSON-сообщения.

Рисунок 3. Просмотр событий

В разделе Consumers можно посмотреть какие сервисы читают топики, их текущий статус и значение параметра Consumer Lag (см. Рисунок 4).

Если значение Consumer Lag растёт, это означает что:

• события приходят быстрее, чем обрабатываются.
• возможна задержка обновления интерфейса.

Внимание! Kafka UI используется только для мониторинга событий интерфейса. Не является системой фоновых задач. Не используется для обработки длительных процессов.