Flink CDC Source和Sink模块

本文向您介绍基于Flink CDC的数据摄入作业的SourceSink模块及其支持使用的连接器。

连接器参数配置

您可以在基于Flink CDC的数据摄入作业中配置 Source 及 Sink 连接器的参数。支持的连接器及相应的参数请参考下文。

# Source 模块
source:
  type: mysql # 或其他连接器标识符
  name: MySQL Source
  # 其他参数。使用 key: value 表示。

# Sink 模块
sink:
  type: paimon # 或其他连接器标识符
  name: Paimon Sink
  # 其他参数。使用 key: value 表示。

支持的连接器

连接器

支持类型

Source

Sink

MySQL

说明

支持连接RDS MySQL版、PolarDB MySQL版及自建MySQL。

×

流式数据湖仓Paimon

×

消息队列Kafka

说明

仅实时计算引擎 VVR 8.0.10 及更高版本支持。

Upsert Kafka

×

StarRocks

×

实时数仓Hologres

×

日志服务SLS

说明

仅实时计算引擎 VVR 11.1 及更高版本支持。

×

MongoDB

说明

仅实时计算引擎 VVR 11.2 及更高版本支持。

×

大数据计算服务MaxCompute

×

说明

仅实时计算引擎 VVR 11.1 及更高版本支持。

SelectDB

×

说明

仅实时计算引擎 VVR 11.1 及更高版本支持。

Print

×