и снова я тут.
собссно тема. не знаю как лучше сделать. хранилище - эластик.
есть топик А по нему летят документы А, есть топик Б в него летят документы Б.
документ А содержит лист документов Б.

документы Б могут удаляться, или же менять владельца (документ А).

в топике Б документы летят с одним только статусом - криейт апдейт и делет. документ Б содержит ключ от документа А.

есть требование в выдаче отдавать список документов А, (в каждом внутри список документов Б).

собссно варианта два:
1) мы держим два индекса и на лету при выдаче их джоиним. ну типа запрос в первый индекс и во второй а потом склеиваем. - производительность конечно же упадет.
2) мы получаем некий апдейт документа Б, идем по айди документа Б в индекс А, находим там документ А, и смотрим айди документа А в документе Б. и если они одинаковые обновляем документ А. если нет то удаляем из документа А и вкладываем документ Б в новый документ А. - тут просаживаемся по перформансу уже на инсерте. да еще и заморочки с версионированием получаем.

вроде в эластике есть штука с почти классическими джойнами но ее советуют не использовать.

нет никакой бд. эластик и есть документная бд. да. в данном контексте шла речь про документную бд.

в общем у нас есть А с листом Б внутри. операции есть где Б добавляется в А или Б удаляется из А.

есть топик куда летят А есть топик куда летят Б (с айдишкой на А).

я всё же склоняюсь к одному индексу куда буду складывать и А и Б (отыскивая их по айди А и просто добавляя в лист.

суть сервиса - быстрый ответ пользователю поэтому данные надо держать типа подготовленными. наверное это ближе всего к CQRS и последнее его звено.

тут уже скорее специфика эластика пошла. я читаю сущность А из бд, добавляю в нее элементы Б из топика и кладу А+Б в бд. но. транзакций никаких нет :) там вроде есть версионность. типа оптимистическая блокировка. играюсь с ней. суть в том что если не смог вложить Б в А то просто не коммичу мессадж в кафке и делаю попытку еще раз пока не будте успеха в сохранении.

мы ограничены в списке технологий - кафка и эластик. причем с рестхл-клиентом. хотя это наверное и к лучшему :)

кафкастримз можно. ты там выше какое то хранилище я так понял упомянул. по кафкастримз не очень понял идею, сорян.

если ты пишешь петпроект где один запрос в день то не нужно. шляпа это ты ))