Настройка подключения и просмотр событий в Apache Kafka

Для настройки подключения и просмотра событий взаимодействия сервисов в Системе рекомендуется использовать стороннее ПО Offset Explorer – графический клиент для работы с Apache Kafka.

После запуска Offset Explorer требуется подключиться к новому кластеру, нажав ПКМ на папку «Clusters» и выбрав действие «Add New Connection». В форме подключения нужно указать хост и порт подключения Zookeper «localhost 2181».

img

В этой же форме открыть вкладку Advanced и в поле Bootstrap servers вручную прописать хост и порт, на которых развернут Apache Kafka, например, «localhost: 9092».

img

Нажать кнопку [Connect], после чего в левом вертикальном меню кластера в папке «Topics» появятся топики всех сервисов Системы, которые прописаны разработчиками Системы и передаются в текущий кластер Apache Kafka.

Нажатием ЛКМ по строке нужного топика откроется его карточка. Рекомендуется в блоке Content Types для полей Key и Value выбрать значения «string» для применения читаемого формата событий. Для сохранения изменений нажать кнопку [Update].

Для просмотра списка событий текущего топика нужно перейти на вкладку Data и нажать кнопку img для того, чтобы Offset Explorer загрузил список событий из Apache Kafka и отобразил их в табличном представлении.

img

​

По каждому событию передается следующая информация:

  • Partition – часть топика, куда записывается сообщение.

  • Offset – позиция сообщения в партиции.

  • imestamp – время отправки.

  • Key – ключ сообщения.

  • Value – тело сообщения.

Для отображения тела сообщения события можно в нижнем блоке открыть вкладку Value и выбрать формат отображения в строке «View Data As».

Данные события являются результатом взаимодействия различных сервисов внутри Системы. Если один сервис обращается к другому, а соответствующие события не попадают в Offset Explorer, можно предположить наличие ошибок взаимодействия.