概览

Pipeline Connectors #

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

Supported Connectors #

连接器 类型 支持的外部系统
Apache Doris Sink
  • Apache Doris: 1.2.x, 2.x.x
    		•
    Elasticsearch Sink
  • Elasticsearch: 6.x, 7.x, 8.x
    		•
    Kafka Sink
  • Kafka
    		•
    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
    		•
    Paimon Sink
  • Paimon: 0.6, 0.7, 0.8
    		•
    StarRocks Sink
  • StarRocks: 2.x, 3.x
    		•

    Develop Your Own Connector #

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

    Back to top