меня есть kafka.
Там вижу такую проблему, у меня есть топик, и допустим один продюсер кидает в этот топик сообщение, которое адресованно только одному консюмеру, кому из них они определяют из содержимого. Проблема в том, что каждый читает кому это сообщение. И если каждый будет запрашивать их. Это что то близкое к обработки x^2 по чтению.
Возможное решение что я вижу. Это микросервис создаёт запрос в шину, мол хочу такие то данные. И там будут данные с адресом топика куда он их будет ждать.
Мы вместо того чтобы кидать в один общий топик, создадим на это сообщение свой топик под каким нибудь guid.
Т.е запрашиваем данные, создаём топик, подписываемся на него, и ожидаем в нем данные.
На сколько это решение является ерундой ?
Настрой роутинг сообщений
по топику на ровно одно сообщение? ну камон
Я Кафку вижу как источник событий, удалили товар, добавили товар. Вопросов нет. Но когда задача стоит как обмен сообщениями, т.е не меняющие состояние, шина сообщений, или как ее ещё обзывают. Тут у меня поднимаются вопросы. В частности. Есть бекенд. У него куча сессий. И все они запрашивают допустим товар. Каждая сессия свой товар для пользователя. И тут я думаю что происходит что то не правильное.
Тут нужен не топик, а очередь
Ничего не скажу про кафку но твой сценарий с реализаций запрос-ответ делается элементарно на ребите, особенно с масстранзитом
Sounds like producer/consumer schema
Есть уже решение твоей проблемы в Кафке
yep, but I don't understand how to deliver one topic to a specific consumer. let's say the third out of ten. It is he who will indicate that the message has been processed.
Обсуждают сегодня