Управление группой потребителей

Создать группу потребителей

Посмотреть состояние группы

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

1. Подключитесь к Serverless Queue.
2. Перейдите в раздел Consumer Groups.
3. Перейдите в нужную группу потребителей.
4. В параметрах доступны для просмотра:

   • Lag для каждого раздела — разница между последним сообщением и прочитанным;
   • Offset — текущая позиция чтения;
   • Partition assignment — обрабатываемые разделы, если есть активные потребители.

Для детального анализа используйте вкладку Partitions.

Сбросить смещения

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

1. Подключитесь к Serverless Queue.

2. Перейдите в раздел Consumer Groups.

3. Нажмите кнопку Update offsets.

4. Укажите, с какой позиции группа будет читать сообщения после следующего запуска потребителя:

   • To beginning — начать с самых старых сообщений;
   • To end — пропустить все и читать только новые.

5. Нажмите кнопку Apply.

Сброс применится при следующем запуске потребителя.

Удалить все смещения

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

1. Подключитесь к Serverless Queue.
2. Перейдите в раздел Consumer Groups.
3. Нажмите кнопку Delete offsets.
4. Подтвердите действие.

Если после этого группа не имеет активных потребителей, она будет автоматически удалена.

Удалить группу потребителей

Можно удалить только группу потребителей в статусе init. Другие группы потребителей удалить напрямую нельзя. Они удалятся автоматически, если в группе неактивны все потребители и удалены все смещения.

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

1. Подключитесь к Serverless Queue.
2. Перейдите в раздел Consumer Groups.
3. Нажмите на иконку удаления для удаляемой группы потребителей.
4. Подтвердите удаление.