Overview
This documentation is for an unreleased version of Apache Flink CDC. We recommend you use the latest stable version.

Connectors #

Flink CDC provides several source and sink connectors to interact with external systems. You can use these connectors out-of-box, by adding released JARs to your Flink CDC environment, and specifying the connector in your YAML pipeline definition.

Supported Connectors #

Connector Supported Type External System
Apache Doris Sink
  • Apache Doris: 1.2.x, 2.x.x
    		•
    MySQL Source
  • MySQL: 5.6, 5.7, 8.0.x
  • RDS MySQL: 5.6, 5.7, 8.0.x
  • PolarDB MySQL: 5.6, 5.7, 8.0.x
  • Aurora MySQL: 5.6, 5.7, 8.0.x
  • MariaDB: 10.x
  • PolarDB X: 2.0.1
    		•
    StarRocks Sink
  • StarRocks: 2.x, 3.x
    		•

    Develop Your Own Connector #

    If provided connectors cannot fulfill your requirement, you can always develop your own connector to get your external system involved in Flink CDC pipelines. Check out Flink CDC APIs to learn how to develop your own connectors.

    Flink CDC sources introduces before 3.0 are still available as normal Flink connector sources. You can find more details in the overview page of legacy Flink CDC sources.

    Back to top