170 похожих чатов

У меня вопрос на сколько жизнеспособная идея решения проблемы. У

меня есть kafka.
Там вижу такую проблему, у меня есть топик, и допустим один продюсер кидает в этот топик сообщение, которое адресованно только одному консюмеру, кому из них они определяют из содержимого. Проблема в том, что каждый читает кому это сообщение. И если каждый будет запрашивать их. Это что то близкое к обработки x^2 по чтению.
Возможное решение что я вижу. Это микросервис создаёт запрос в шину, мол хочу такие то данные. И там будут данные с адресом топика куда он их будет ждать.
Мы вместо того чтобы кидать в один общий топик, создадим на это сообщение свой топик под каким нибудь guid.
Т.е запрашиваем данные, создаём топик, подписываемся на него, и ожидаем в нем данные.
На сколько это решение является ерундой ?

8 ответов

23 просмотра

Настрой роутинг сообщений

по топику на ровно одно сообщение? ну камон

Сергей-(F L ) Автор вопроса
Etki
по топику на ровно одно сообщение? ну камон

Я Кафку вижу как источник событий, удалили товар, добавили товар. Вопросов нет. Но когда задача стоит как обмен сообщениями, т.е не меняющие состояние, шина сообщений, или как ее ещё обзывают. Тут у меня поднимаются вопросы. В частности. Есть бекенд. У него куча сессий. И все они запрашивают допустим товар. Каждая сессия свой товар для пользователя. И тут я думаю что происходит что то не правильное.

Сергей (F L )
Я Кафку вижу как источник событий, удалили товар, ...

Ничего не скажу про кафку но твой сценарий с реализаций запрос-ответ делается элементарно на ребите, особенно с масстранзитом

Есть уже решение твоей проблемы в Кафке

Сергей-(F L ) Автор вопроса
Ihor Volokhovych
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.

Похожие вопросы

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта