Set up end-to-end Change Data Capture (CDC) pipelines on Confluent Cloud using Debezium source connectors, Flink for transformation, and Tableflow for data lake integration. Supports JSON_SR, Avro, and Protobuf formats. Handles schemaless topics (plain JSON without SR) and multi-event topics. This skill handles the complete workflow from database to Iceberg/Delta tables.
Install
npx skills add confluentinc/agent-skills --skill confluent-cloud-cdc-tableflownpx skills add confluentinc/agent-skills --skill confluent-cloud-cdc-tableflow -a claude-code -gnpx skills add confluentinc/agent-skills --skill confluent-cloud-cdc-tableflow -a codex -ggemini skills install https://github.com/confluentinc/agent-skills.git --path skills/confluent-cloud-cdc-tableflowgh skill install confluentinc/agent-skills confluent-cloud-cdc-tableflowgit clone --depth 1 https://github.com/confluentinc/agent-skills /tmp/confluentinc__agent-skills
mkdir -p ~/.claude/skills ~/.agents/skills
cp -R /tmp/confluentinc__agent-skills/skills/confluent-cloud-cdc-tableflow ~/.claude/skills/confluent-cloud-cdc-tableflow # Claude Code
cp -R /tmp/confluentinc__agent-skills/skills/confluent-cloud-cdc-tableflow ~/.agents/skills/confluent-cloud-cdc-tableflow # Codex, Cursor, Gemini CLI, Copilot, OpenCode