Flink CDC のソースおよびシンクモジュール - Realtime Compute for Apache Flink

このドキュメントでは、Flink Change Data Capture (CDC) データインジェストジョブの source および sink モジュールについて説明し、サポートされているコネクタを一覧表示します。

構文

Flink CDC データインジェストジョブの source および sink モジュールでコネクタオプションを設定します。

# source モジュール
source:
  type: mysql # または別のコネクタ識別子
  name: MySQL Source
  # その他のパラメーター。 key: value のペアを使用します。

# sink モジュール
sink:
  type: paimon # または別のコネクタ識別子
  name: Paimon Sink
  # その他のパラメーター。 key: value のペアを使用します。

サポートされているコネクタ

コネクタ	サポートタイプ
コネクタ	ソース	シンク
MySQL 説明 ApsaraDB RDS for MySQL、PolarDB for MySQL、およびセルフマネージド MySQL に接続します。	√	×
Paimon	×	√
Kafka	√ 説明 Ververica Runtime (VVR) 8.0.10 以降が必要です。	√
Upsert Kafka	×	√
StarRocks	×	√
Hologres	×	√
SLS	√ 説明 VVR 11.1 以降が必要です。	×
MongoDB	√ 説明 VVR 11.2 以降が必要です。	×
MaxCompute	×	√ 説明 VVR 11.1 以降が必要です。
SelectDB	×	√ 説明 VVR 11.1 以降が必要です。
PostgreSQL CDC (パブリックプレビュー)	√ 説明 VVR 11.4 以降が必要です。	×
Print	×	√