Пообщался я значит сегодня с интересным человеком. И он мне накинул интересную мысль по поводу Transaction Outbox. Думаю не надо объяснять механику Transaction Outbox и зачем это надо) В общем. Связка такая Со стороны базы данных, мы как положенно коммитим свои эвенты в транзакциях. И они как положенно появляются в табличке. Но мы не настраиваем воркеры на то что бы читать из этой таблички и как то их обрабатывать, мы делаем хитрее. Мы делаем логическую репликацию таблички с эвентами. Парсим WAL журнал с помощью CDC debezium и благополучно складываем это в kafka. С партициями, с консьюмер группами и все как положено. А дальше читает кто как хочет. Хочет батчами. Хочет по одному. Хочет перечитывает. И все это сразу разбито по партициям и реплицированно по нодам. Кайф) Интересная мыслишка в общем)