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

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

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

8 ответов

7 просмотров

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

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

Сергей-(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.

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

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

Сообщение* в закодированном виде. То есть, просто сделать sendMessage?text=Привет бла-бла! не получится, надо в HEX переводить, и добавлять процент, типа такого: sendMessage?t...
КТ315
21
Anyone here suffers from unexplained aural migraines, who would be up for talking for a bit? Doesn't *have* to be aural, but I am not asking about headaches, I mean actual mi...
Martin Rys
58
А случайно нет ли в паскале штатной возможности передать указатель и количество туда где array of в качестве аргумента?
zamtmn
25
> комьюнити я бы не судил по этому чату. Как мы видели по статам просмотров нескольких телеговских постов, то в чате их набивается 30-40 или даже выше, когда как общаются акти...
Constantin F.
4
приветы , подскажите что я не так сделал , почему у меня скрипт не работает в программе Revit ? ;Autohotkey_RU IfWinActive ("ahk_exe Revit.exe") ; только в открытом Revit Gu...
Anton Terentev
2
Ну раз я пока тут, задам пару глупых вопросов. Зачем писать на ассемблере если компилятор довольно умный, а ассемблер много времени занимает? В каких прикладных задачах сейчас...
Максим Рябцев
20
Как сделать чтобы short точно был 2 байта, int точно 4 байта ?(без стандартных библиотек, ну типа без int16_t, int32_t)
#
8
Всем привет. Испытываю проблемы в работе БД, а именно огромного роста логов, такого характера: 024-05-16 18:39:07 +05 sentry sentry [unknown] 1050169 7-1 app-sentry01.corp.ru>...
Alexey
2
Почему Telegram пишет, что объект media не найден, хотя на самом деле я его передаю? Делаю на urllib, без зависимостей, так надо. Вызываю метод sendMediaGroup с таким JSON: ...
Alexey S
1
Хм. А телеграм апи работают через HTTP?
The Bird of Hermes
14
Карта сайта