просто свалил данные и делаешь каждый раз заново запросы - это не про event driven
если вам нужен список удаленных сообщений - ставьте kafka-streams прилогу и собирайте отдельный топик таких сообщений, кто мешает?
надо материализовать это для метрик - пробросили только нужные для метрик данные в кликхаус, и радуетесь.
Там нужен список БЕЗ удалённых. Т.е. вычитываем всё удалённое в память и дальше идём по сообщениям фильтруя удалённые.
Обсуждают сегодня