Сначала используем системный аккаунт администратора для входа в систему

1. Используйте конфигурацию системы для входа с учётной записью администратора (admin/admin)

2. После входа в систему перейдите в Kafka Manager -> Cluster, нажмите Add New Cluster и заполните информацию о кластере согласно подсказкам

3. Перейдите в Setting -> User, нажмите Add User для добавления пользователей в систему (test и testAdmin). Роль пользователя test — Member, роль пользователя testAdmin — Admin

Важно: помимо системного аккаунта администратора необходимо создать аккаунт с ролью admin, иначе система будет выдавать ошибки в местах, где требуется отправка сообщений администраторам (например, при создании задачи)

4. После успешного добавления пользователей перейдите в Setting -> Team, нажмите New Team и заполните название команды (test_team)

5. После создания команды нажмите на кнопку team Operation и выберите addUser. Выберите только что созданного пользователя и нажмите Add User To Team для его добавления в команду

6. Нажмите на изображение в правом верхнем углу для выхода из системы

Использование созданного пользователя test для входа в систему

1. Войдите в систему с помощью созданного пользователя (test)

2. Создайте тему

• Перейдите в Topic -> My Task, нажмите Create Topic Task и заполните информацию о теме. Создайте тему (topic_test), система отправит уведомление администратору

• Выйдите из системы и войдите с использованием учётной записи testAdmin
• В разделе Approve выберите отправленную тему (topic_test) и нажмите check. Выберите необходимый кластер и нажмите Approve.
• После успешного создания темы система отправит сообщение пользователю test

3. Произведите сообщение

• После создания темы перейдите в Topic -> Topic List, выберите созданную тему (topic_test) и выберите mock операцию
• Введите ключ и значение сообщения, нажмите Send. На правой стороне появится сообщение PRODUCER TOPIC SUCCESS, что означает успешное производство

4. Мониторинг производства

• После успешного производства сообщений по теме (topic_test) перейдите в Monitor -> Producer
• Нажмите на topic (topic_test), чтобы перейти к информации о производстве. Здесь вы увидите скорость производства

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

Важно: если не выбрать Commit The Record Consumed, то в consumer информация о потреблении не будет отображаться

• Перейдите в Topic -> Queries
• Выберите кластер и тему, затем выберите Commit The Record Consumed и нажмите Query
• После потребления сообщений на правой стороне отобразится информация о потреблённых сообщениях

• Выберите Consumer Topic By Offset, укажите раздел, введите смещение и нажмите Query (для потребления из указанного раздела)
• После потребления на правой стороне отобразятся потреблённые сообщения

6. Мониторинг потребления

• Перейдите в Monitor -> Consumer, выберите тему, а затем topic (topic_test). Здесь вы сможете увидеть состояние потребления группы

• Нажмите на alert после группы потребления, чтобы добавить alert для мониторинга группы. Система отправит уведомление, когда lag достигнет заданного значения

• После этого нажмите на группу потребления и посмотрите график lag