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

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

AKHQ
kafkactl

В AKHQ нельзя вручную создать группу потребителей. Группа появится автоматически, когда хотя бы один потребитель начнет читать сообщения из топика, указав в конфигурации идентификатор группы group.id.

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

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

Подключитесь к Serverless Queue.
Перейдите в раздел Consumer Groups.
Перейдите в нужную группу потребителей.
В параметрах доступны для просмотра:
- Lag для каждого раздела — разница между последним сообщением и прочитанным;
- Offset — текущая позиция чтения;
- Partition assignment — обрабатываемые разделы, если есть активные потребители.

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

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

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

Подключитесь к Serverless Queue.
Перейдите в раздел Consumer Groups.
Нажмите кнопку Update offsets.
Укажите, с какой позиции группа будет читать сообщения после следующего запуска потребителя:
- To beginning — начать с самых старых сообщений;
- To end — пропустить все и читать только новые.
Нажмите кнопку Apply.

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

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

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

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

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

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

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

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

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