CDC (change data capture) читает журнал изменений базы (WAL в PostgreSQL, binlog в MySQL) и публикует каждое изменение строки как событие — обычно в Kafka через Debezium.
А ещё События CDC — изменения таблиц, а не бизнес-события; для интеграции между командами лучше outbox
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Как работает. База и так пишет все изменения в журнал для восстановления и репликации. CDC-коннектор подключается как реплика (логическая репликация PostgreSQL, binlog MySQL), читает поток изменений INSERT/UPDATE/DELETE и публикует их событиями с состоянием строки до и после. Debezium — самый распространённый инструмент, работает в Kafka Connect.
Плюсы:
Применения: обновлять Elasticsearch и кэши, поток в ClickHouse или хранилище данных, публикация событий через outbox (Debezium читает таблицу outbox и превращает строки в события), миграции между базами без простоя.
Ограничения: события отражают схему таблиц — потребители связываются со внутренней структурой чужой базы; изменение схемы ломает потребителей. Поэтому для интеграции между сервисами публикуют осмысленные события через outbox, а «сырой» CDC — для внутренних нужд. Нужно следить за слотом репликации: остановленный коннектор держит WAL и может заполнить диск.
Почему 2PC не подходит, сага и компенсации, хореография vs оркестрация, CDC и outbox-relay, eventual consistency и границы.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto