обработку ивентов последовательно на одном и том же консюмере, если эти ивенты содержат какой-то общий признак? Например, ивенты {"shop":1, "action":3} и {"shop":1, "action":5} отправить на одного и того же консюмера (анализ атрибута shop). Цель — исключить одновременную обработку ивентов с одинаковым shop.
У меня похожая задача решена так - есть входящий поток событий, его я разгребаю консьюмером который шардирует по ключу shop сообщения и перекладывает их в N очередей. На каждую очередь подписан строго 1 консьюмер с prefech count=1. Таким образом обеспечивается что один shop будет обработан строго одним консьюмером и строго по порядку(если последнее не нужно - то префеч можно убрать)
Обсуждают сегодня