Как было выстроено взаимодействие между базами данных и Kafka?

Расскажите, кто был источником истины и в каком направлении передавались изменения: БД → Kafka через outbox/CDC или Kafka → БД через consumer. Простая двойная запись ненадёжна.

Если бизнес-запись и публикация выполняются независимо, сбой между ними оставляет систему несогласованной. Outbox фиксирует событие вместе с данными, CDC читает изменения из журнала; оба подхода требуют контроля доставки и порядка.

При чтении из Kafka обработчик должен выдерживать повторы, сохранять проекцию и корректно подтверждать прогресс. Транзакция Kafka сама по себе не делает произвольную внешнюю БД участником общей атомарной транзакции. В ответе назовите реальные гарантии своего контура.