и каждый кусок обрабатывает нода. к примеру их 5.
Виды запросов
1) Посылается сообщение в топик1, его читают все ноды, только одна понимают что она может на него ответить и кидает ответ в топик1_1
2)Посылается сообщение в топик2. посылающий знает id ноды и прикладывает его к сообщению. считать сообщение должна только нужная нода и отправить ответ в топик2_2. видимо тут нужен какойто id на пару (вопрос, ответ)
3) обычная очередь для тяжелых задач: чтобы пул воркеров их по одной расхватывал и начинал обрабатывать. потом ответ в како то топик для ответов отдавал.
Особенно непонятна ситуация со 2м видом запросов.
Подходит ли сюда кафка или нужно будет пилить какие то кастыли чтобы реализовать то что мне нужно и легче взять кролика или еще что то ?
Второй пункт проще всего сделать на клиенте - каждый читает все, чужое игнорирует. Но надо производительность считать. Если персистентность важна, то для кролика стоит внимательно прочитать все ограничения, там гарантии не очень очевидны (
Обсуждают сегодня