Problem
Downstream systems (search, analytics, cache, replicas) need database changes. Polling is slow; dual-write is unreliable.
Also known as: cdc-pattern, debezium, log-based-cdc
Capture database changes (insert/update/delete) in real-time and stream them to downstream systems.
Downstream systems (search, analytics, cache, replicas) need database changes. Polling is slow; dual-write is unreliable.
Medium — Kafka cluster, Connect workers, schema registry
High — connector monitoring, schema evolution, rebalancing
Medium — event modeling, schema design
Connector lag → stale downstream
Schema change breaks consumer → data loss
Large transaction OOMs connector
Kafka outage → backlog, replay on recovery
DDL not captured → silent data loss