Про то, как мы распиливали монолит на MSA

[ptr128]

CDC уж очень громоздок и требует обслуживания. Поигрались и выкинули. Сделали свой велосипед, в виде таблички с идентификатором таблицы, идентификатором записи, типом операции и rowversion. Соответственно триггеры на все исходные таблицы топиков, которые в эту табличку и пишут. Ну и сервис только одной этой таблички, который уже публикует в топики.

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