Supported connectors - Realtime Compute for Apache Flink

This topic describes the table types and connectors supported by Realtime Compute for Apache Flink.

Understand table types

Realtime Compute for Apache Flink supports Flink SQL for defining tables that map to upstream and downstream storage. Alternatively, you can use the Datastream API for read and write operations. The following Flink SQL table types are supported:

Source table: The entry point for a data stream. It continuously reads raw event data from external systems like Kafka or MySQL CDC.
Dimension table: A reference table used to enrich streaming data with static or infrequently updated information, such as user or product details.
Sink table: The exit point for data processing. It writes results (e.g., aggregated or joined data) to destination systems like data warehouses, databases, or message queues.

Overview of supported connectors

Relational databases

NoSQL databases

Message queues

Data warehouses

Data lakes

Log and object storage services

Tools and debugging

Key-value and time series databases

General

Details of supported connectors

Connector	Supported table types			Execution mode	API type	Supports updates or deletions to sink table data
Connector	Source table	Dimension table	Sink table	Execution mode	API type	Supports updates or deletions to sink table data
MySQL Note Supports connections to ApsaraDB RDS for MySQL, PolarDB for MySQL, and self-managed MySQL.	√	√	√	Streaming	SQL, DataStream, and YAML for data ingestion	Yes
Hologres	√	√	√	Streaming and batch	SQL, DataStream, and YAML for data ingestion	Yes
Message Queue for Apache Kafka	√	×	√	Streaming	SQL, DataStream, and YAML for data ingestion	No. Only supports inserting data.
MaxCompute	√	√	√	Streaming and batch	SQL and DataStream	No. Only supports inserting data.
Paimon	√	√	√	Streaming and batch	SQL and YAML for data ingestion	Yes
SLS	√	×	√	Streaming	SQL and DataStream	No. Only supports inserting data.
StarRocks	√	√	√	Streaming and batch	SQL, DataStream, and YAML for data ingestion	Yes
DataHub	√	×	√	Streaming and batch	SQL and DataStream	No. Only supports inserting data.
MongoDB	√	√	√	Streaming	SQL and DataStream	Yes
JDBC	√	√	√	Streaming and batch	SQL	Yes
OSS	√	×	√	Streaming and batch	SQL and DataStream	No. Only supports inserting data.
ApsaraDB RDS for MySQL Note The ApsaraDB RDS for MySQL connector will no longer be supported. Use the MySQL connector instead.	×	√	√	Streaming and batch	SQL	Yes
ApsaraMQ for RocketMQ	√	×	√	Streaming	SQL and DataStream	No. Only supports inserting data.
Lindorm	×	√	√	Streaming	SQL	Yes
Tair (Redis OSS-compatible)	×	√	√	Streaming	SQL	Yes
Tair connector	×	×	√	Streaming	SQL	Yes
ApsaraDB for HBase	×	√	√	Streaming	SQL	Yes
AnalyticDB for MySQL 3.0	√	√	√	Streaming and batch	SQL	Yes
AnalyticDB for PostgreSQL	×	√	√	Streaming and batch	SQL	Yes
PolarDB for PostgreSQL (Compatible with Oracle) 1.0 connector	×	×	√	Streaming and batch	SQL	Yes
Upsert Kafka	√	×	√	Streaming	SQL and YAML for data ingestion	Yes
Elasticsearch	√	√	√	Streaming and batch	SQL and DataStream	Yes
ClickHouse	×	×	√	Streaming and batch	SQL	Yes
Tablestore (OTS)	√	√	√	Streaming mode	SQL	Yes
SelectDB	×	×	√	Streaming and batch	DataStream and SQL	Yes
InfluxDB	×	×	√	Streaming	SQL	No
Postgres CDC (Public Preview)	√	×	×	Streaming	SQL	N/A
OceanBase (public preview)	√	√	√	Streaming and batch	SQL	Yes
Milvus (public preview)	×	×	√	Streaming	SQL	Yes
Iceberg	√	×	√	Streaming and batch	SQL	Yes
Faker	√	√	×	Streaming and batch	SQL	N/A
Blackhole	×	×	√	Streaming and batch	SQL	Yes
Datagen	√	×	×	Streaming and batch	SQL	N/A
Print	×	×	√	Streaming and batch	SQL and YAML for data ingestion	Yes
Hudi (Being deprecated)	√	×	√	Streaming and batch	SQL and DataStream	Yes