CDC Pipelines with Debezium

When to Use

Activate this skill when the task involves:

• Setting up Debezium connectors for PostgreSQL, MySQL, or Oracle
• Interpreting or transforming CDC change events (insert/update/delete/truncate)
• Designing CDC pipelines: database → Kafka → data lake / warehouse
• Implementing the Outbox pattern for transactional CDC
• Troubleshooting replication lag, snapshot failures, or schema evolution
• Integrating CDC streams with Apache Flink, Spark Structured Streaming, or dbt

Core Architecture