Debezium And Kafka Connect CDC

Overview

Use this skill when database changes must be captured and delivered through Debezium and Kafka Connect. It helps agents define connector safety, snapshot behavior, schema handling, and downstream CDC contracts.

When to Use

• setting up Debezium connectors for PostgreSQL, MySQL, MongoDB, SQL Server, or Oracle
• designing Kafka-based CDC from transactional databases
• handling initial snapshots, incremental streaming, and connector recovery
• feeding downstream stream processors, lakehouse sinks, or search indexes
• managing schema evolution when source tables change

Do not use this when changes can be captured through application-level events or batch extracts are sufficient for freshness requirements.

Workflow