Flink CDC source and sink modules - Realtime Compute for Apache Flink

This document describes the source and sink modules for Flink Change Data Capture (CDC) data ingestion jobs and lists the supported connectors.

Syntax

Configure connector options in source and sink modules for Flink CDC data ingestion jobs.

# source module
source:
  type: mysql # Or another connector identifier
  name: MySQL Source
  # Other parameters. Use key: value pairs.

# sink module
sink:
  type: paimon # Or another connector identifier
  name: Paimon Sink
  # Other parameters. Use key: value pairs.

Supported connectors

Connector	Supported type
Connector	Source	Sink
MySQL Note Connects to ApsaraDB RDS for MySQL, PolarDB for MySQL, and self-managed MySQL.	√	×
Paimon	×	√
Kafka	√ Note Requires Ververica Runtime (VVR) 8.0.10 or later.	√
Upsert Kafka	×	√
StarRocks connector	×	√
Hologres	×	√
SLS	√ Note Requires VVR 11.1 or later.	×
MongoDB	√ Note Requires VVR 11.2 or later.	×
MaxCompute	×	√ Note Requires VVR 11.1 or later.
SelectDB	×	√ Note Requires VVR 11.1 or later.
Print	×	√