🚩Кейс: Балансировка нагрузки на консьюмерах (Back Pressure на примере RabbitMQ)

⚠️ Чтобы консьюмер не пытался обработать больше сообщений, чем позволяют его ресурсы, необходимо ограничить количество одновременно получаемых сообщений.

1️⃣ Использовать параметр prefetch_count для ограничения числа поступающих сообщений на консьюмер.

2️⃣ Консьюмер получит указанное число сообщений.

3️⃣ Консьюмер вернёт ack (подтверждение) брокеру только после обработки всех полученных сообщений.

4️⃣ После получения ack брокер отправит следующую партию сообщений, соблюдая заданный prefetch_count.

P.S. В следующих видео расскажу про Back Pressure в Kafka.

Системный анализ | Дмитрий Помаскин