Realtime Compute for Apache Flink mendukung berbagai format data untuk digunakan dengan berbagai connector.
Format data
|
Format data |
Connector yang didukung |
|
JSON |
Apache Kafka connector, Upsert Kafka connector, Elasticsearch connector, OSS connector, ApsaraDB for MongoDB connector, dan StarRocks connector |
|
Canal |
Apache Kafka connector dan OSS connector |
|
Debezium |
Apache Kafka connector dan OSS connector |
|
Maxwell |
Apache Kafka connector dan OSS connector |
|
CSV |
Apache Kafka connector, Upsert Kafka connector, ApsaraMQ for RocketMQ connector, StarRocks connector, dan OSS connector |
|
Avro |
Apache Kafka connector, Upsert Kafka connector, dan OSS connector |
|
Confluent Avro |
Apache Kafka connector dan Upsert Kafka connector |
|
Raw |
Apache Kafka connector, Upsert Kafka connector, dan OSS connector |
|
Parquet |
OSS connector, yang digunakan di Realtime Compute for Apache Flink yang menggunakan Ververica Runtime (VVR) 6.0.7 atau versi lebih baru |