Supported connectors

Realtime Compute for Apache Flink supports multiple table types and connectors for reading from and writing to external storage through Flink SQL and the DataStream API.

Table types

Realtime Compute for Apache Flink defines tables through Flink SQL or the DataStream API to read from and write to external storage. Flink SQL supports the following table types:

Source table: Entry point for a data stream. Continuously reads raw event data from external systems such as Kafka or MySQL CDC.
Dimension (lookup) table: Reference table that enriches streaming data by joining static or slowly changing dimension data, such as user or product details.
Sink table: Exit point for data processing. Writes results such as aggregated or joined data to a destination system such as a data warehouse, database, or message queue.

Relational database

NoSQL database

Message queue

Data warehouse

Data lake

Log and object storage services

Tools and debugging

Key-value and time series databases

General

Connector support details

Connector	Flink SQL			Flink CDC		Execution mode	API type	Sink updates
Connector	Source table	Dimension table	Sink table	Data source	Sink	Execution mode	API type	Sink updates
MySQL	√	√	√	√	×	Streaming mode	SQL, DataStream, and Flink CDC	Yes
Hologres: Real-time data warehouse	√	√	√	×	√	Streaming and batch	SQL, DataStream, and Flink CDC	Yes
Kafka	√	×	√	√	√	Streaming	SQL, DataStream, and YAML for data ingestion	Only inserts are supported.
MaxCompute	√	√	√	×	√	Streaming and batch	SQL, DataStream, and Flink CDC	Only inserts are supported.
Paimon	√	√	√	×	√	Streaming and batch modes	SQL and Flink CDC	Yes
Log Service	√	×	√	√	×	Streaming mode	SQL, DataStream, and Flink CDC	Only inserts are supported.
StarRocks	√	√	√	×	√	Streaming and batch modes	SQL, DataStream, and Flink CDC	Yes
DataHub	√	×	√	×	×	Streaming and batch modes	SQL and DataStream	Only inserts are supported.
MongoDB	√	√	√	√	×	Streaming mode	SQL, DataStream, and Flink CDC	Yes
JDBC	√	√	√	×	×	Streaming and batch modes	SQL	Yes
Object Storage Service	√	×	√	×	×	Streaming and batch modes	SQL and DataStream	Only inserts are supported.
ApsaraDB RDS for MySQL Note The connector is being deprecated. Use the MySQL connector instead.	×	√	√	Use the MySQL connector.	×	Streaming and batch modes	SQL	Yes
Message Queue for RocketMQ	√	×	√	×	×	Streaming mode	SQL and DataStream	Only inserts are supported.
Lindorm	×	√	√	×	×	Streaming mode	SQL	Yes
ApsaraDB for Tair (Redis-compatible)	×	√	√	×	×	Streaming mode	SQL	Yes
ApsaraDB for Tair (Enterprise)	×	×	√	×	×	Streaming mode	SQL	Yes
ApsaraDB for HBase	×	√	√	×	×	Streaming mode	SQL	Yes
AnalyticDB for MySQL 3.0	√	√	√	×	×	Streaming and batch modes	SQL	Yes
AnalyticDB for PostgreSQL	×	√	√	×	×	Streaming and batch modes	SQL	Yes
PolarDB PostgreSQL (Oracle Compatible 1.0) (deprecating)	×	×	√	×	×	Streaming and batch modes	SQL	Yes
Upsert Kafka	√	×	√	×	√	Streaming mode	SQL and Flink CDC	Yes
Elasticsearch	√	√	√	×	×	Streaming and batch modes	SQL and DataStream	Yes
ClickHouse connector	×	×	√	×	×	Streaming and batch modes	SQL	Yes
Tablestore (OTS)	√	√	√	×	×	Streaming mode	SQL	Yes
SelectDB	×	×	√	×	×	Streaming and batch modes	SQL and DataStream	Yes
InfluxDB (deprecating)	×	×	√	×	×	Streaming mode	SQL	Only inserts are supported.
Postgres CDC (public preview)	√	×	×	√	×	Streaming mode	SQL and Flink CDC	N/A
OceanBase (public preview)	√	√	√	×	√	Streaming and batch modes	SQL and Flink CDC	Yes
Iceberg	√	×	√	×	√	Streaming and batch modes	SQL and Flink CDC	Yes
Faker connector	√	√	×	×	×	Streaming and batch modes	SQL	N/A
Blackhole	×	×	√	×	×	Streaming and batch modes	SQL	Yes
Datagen	√	×	×	×	×	Streaming and batch modes	SQL	N/A
Print	×	×	√	×	√	Streaming and batch modes	SQL and Flink CDC	Yes
Hudi (deprecating)	√	×	√	×	×	Streaming and batch modes	SQL and DataStream	Yes