Можливо, ви мали на увазі що для маршрутизації по id це треба менеджити на рівні коду? Тобто писати алгоритм розрахунку черги по відомій айдішці.
Наскільки я розумію, такий підхід використовується коли є обмежена кількість значень (умовна єнамка) по яких треба маршрутизувати. А як бути коли мені треба гарантувати, що всі повідомлення для одного клієнта буде опрацьовувати один консьюмер послідовно?
Дякую за статтю. Корисний аналіз проблеми.
Весь потік повідомлень може бути логічно розбитий на розділи (partitions), кожен з яких може оброблятися окремим процесором незалежно від інших. Наприклад, повідомлення можуть бути розбиті за клієнтом, за типом повідомлення, за типом сутності тощо.
З Кафкою все зрозуміло. Там це підримується з коробки. Можливо, є досвід вирішення цієї проблеми при використанні RabbitMQ? Щось порадите?
Добрий день! Будь ласка, підтвердіть мій акаунт. Дякую
Дякую