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

Connectors #

Flink CDC 提供了多个Source和Sink连接器来与外部系统交互。您可以直接使用这些连接器，只需将 JAR 文件添加到您的 Flink CDC 环境中，并在您的 YAML Pipeline定义中指定所需的连接器。

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 #

    如果现有的连接器无法满足您的需求，您可以自行开发自己的连接器，以将您的外部系统集成到 Flink CDC 数据管道中。查阅 Flink CDC APIs 了解如何开发您自己的连接器。

    在 3.0 版本之前引入的 Flink CDC Source 仍然可以作为普通的 Flink 连接器使用。您可以在 Legacy CDC Sources/概览 中找到更多详细信息。

    Back to top