skills.rest
confluentinc
confluentincOFFICIAL
Explore all skills by this author →
Website𝕏@confluentincGitHub

confluent-cloud-cdc-tableflow

Configure CDC pipelines on Confluent Cloud with Flink SQL and Tableflow sinks.

42|4|Updated Mar 13, 2026
Search Tags:#database replication#lakehouse#cdc#flink#confluent cloud#tableflow
One-click install
npx skills add https://github.com/confluentinc/agent-skills --skill confluent-cloud-cdc-tableflow
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: confluent-cloud-cdc-tableflow
Source: https://github.com/confluentinc/agent-skills/tree/main/skills/confluent-cloud-cdc-tableflow
Command: npx skills add https://github.com/confluentinc/agent-skills --skill confluent-cloud-cdc-tableflow

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes scripts (resource) and references (resource) and assets (resource) components.

What problem does it solve?

This Skill enables users to easily set up end-to-end CDC pipelines on Confluent Cloud that capture database changes and materialize them into Lakehouse tables.

Core Features & Use Cases

  • Complete CDC Workflow Automation: Configures connectors, Flink jobs, and Tableflow sink setup for various databases including PostgreSQL, MySQL, SQL Server, Oracle, and DynamoDB.
  • Supports Multiple Data Formats: Handles JSON_SR, AVRO, and PROTOBUF for high-performance data serialization.
  • Use Case: A data engineer wants to replicate customer and order tables from PostgreSQL into Iceberg tables on S3, with minimal manual intervention, ensuring compliance and data governance.

Quick Start

Provide database and cloud environment details, then review the generated deployment and configuration plan before executing.

Frequently Asked Questions about confluent-cloud-cdc-tableflow

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I set up a CDC pipeline from PostgreSQL to an Iceberg Lakehouse on Confluent Cloud?▼

To set up a CDC pipeline from PostgreSQL to a Lakehouse on Confluent Cloud, you configure source connectors, Flink SQL jobs, and Tableflow sinks to automatically capture database changes and materialize them into Iceberg tables.

What databases are supported for CDC replication into Lakehouse formats using Confluent Cloud?▼

Supported databases for CDC replication into Lakehouse formats include PostgreSQL, MySQL, Oracle, SQL Server, and DynamoDB, enabling you to automatically capture changes and materialize them into Lakehouse tables via Confluent Cloud.

How does Flink SQL integrate with Tableflow for database replication?▼

Flink SQL integrates with Tableflow by processing CDC data streams from connectors and routing them to Tableflow sinks, materializing database changes into Lakehouse table formats with reliable data replication on Confluent Cloud.

What data formats can I use for CDC pipelines replicating databases to a Lakehouse?▼

For CDC pipelines replicating databases to a Lakehouse, you can use JSON_SR, AVRO, and PROTOBUF data formats to ensure high-performance data serialization during the Tableflow sink configuration process.

What prerequisites do I need to automate database replication into Lakehouse tables?▼

To automate database replication into Lakehouse tables, you need to provide specific cloud environment information and database prerequisites to properly generate and review the deployment configuration before executing the pipeline.

Does Confluent Cloud CDC with Tableflow work for DynamoDB replication?▼

Yes, Confluent Cloud CDC with Tableflow supports DynamoDB replication, allowing you to configure connectors and Tableflow sinks to seamlessly capture DynamoDB changes and materialize them into Lakehouse table formats.

Related Skills

Explore More Data & Analytics Skills→
googlegoogle
17.1k

cloud-sql-basics

Manage Cloud SQL instances and databases using gcloud CLI and Terraform.

Official
Advanced
sakamoto-family-smilesakamoto-family-smile

clickhouse-io

Provide ClickHouse analytics patterns for scalable OLAP workloads with MergeTree engines.

Community
Advanced
gAmUssAgAmUssA
2

flink-sql

Develop Apache Flink SQL, Table API, and UDF templates for streaming pipelines.

Community
Advanced
billynewportbillynewport

Enable SQL Server CDC

Enable CDC on SQL Server databases and tables for change capture.

Community
Advanced