Ограничьте количество сообщений, потребляемых по теме

Question

Мой потребитель Kafka должен слушать несколько тем.Каждая тема определяет приоритет, скажем - высокий, низкий и средний.

Потребительская служба должна быть настроена таким образом, чтобы, например,30 исполнителей для обработки сообщений в теме high и 5 исполнителей для обработки каждого сообщения в low и medium тема.

Есть ли способ настроить потребителя на прекращение потребления сообщения из соответствующей темы, если исполнители заняты и выполняют текущие задачи?

Answer 1

Вы не должны передавать работу исполнителю задачи;это вызовет проблемы с фиксацией смещений не по порядку.

Вы должны использовать разные контейнеры слушателей для каждой темы, каждый с разным параметром параллелизма.

Таким образом, контейнер управляет параллелизмом.