Skills
.Work. You
Rest

cdc-debezium

Community

Build CDC pipelines with Debezium and Kafka

Software Engineering#schema evolution#iceberg#cdc#debezium#outbox pattern#kafka connect#flink streaming
Authorivanshamaev
Version1.0.0
Installs0

System Documentation

What problem does it solve?

This Skill helps you set up and operate reliable Change Data Capture (CDC) pipelines with Debezium so database changes can be streamed to Kafka and downstream sinks without missing updates or duplicating data.

Core Features & Use Cases

  • Debezium connector setup: Configure PostgreSQL/MySQL/Oracle CDC connectors, including replication slots, publications, binlog settings, and schema history for DDL propagation.
  • CDC event interpretation: Understand Debezium change event envelopes (before/after/op/source), snapshot modes, tombstone behavior, and truncation events.
  • Production-grade delivery patterns: Implement the outbox pattern, apply Single Message Transforms (SMTs) like ExtractNewRecordState and routing, and integrate with Flink/Spark/dbt and Iceberg/Delta sinks using upsert and CDC semantics.

Quick Start

Ask the AI to generate a complete PostgreSQL Debezium connector configuration for tables customers and orders using snapshot.mode initial, ExtractNewRecordState flattening, DLQ enabled, and Iceberg upsert semantics for a lakehouse sink.

Dependency Matrix

Required Modules

None required

Components

Standard package

💻 Claude Code Installation

Recommended: Let Claude install automatically. Simply copy and paste the text below to Claude Code.

Please help me install this Skill:
Name: cdc-debezium
Download link: https://github.com/ivanshamaev/de-agent-skills/archive/main.zip#cdc-debezium

Please download this .zip file, extract it, and install it in the .claude/skills/ directory.
View Source Repository

Agent Skills Search Helper

Install a tiny helper to your Agent, search and equip skill from 471,000+ vetted skills library on demand.