Debezium читает binlog/WAL базы данных и публикует события изменений в Kafka. Для PostgreSQL — logical replication slot. Каждый INSERT/UPDATE/DELETE становится Kafka сообщением. Это надёжнее polling (не пропускает изменения) и outbox polling (читает прямо из БД лога). Используется для синхронизации данных между сервисами, заполнения read-моделей, поиска. Требует настройки репликации в БД.
Как реализовать CDC (Change Data Capture) с Debezium?
Senior
224 просмотровAFK Offer AI
Что такое OpenAPI и как организовать Swagger в продакшен-проекте?