Data formats
Realtime Compute for Apache Flink supports multiple data formats for use with various connectors.
Data formats
|
Data format |
Supported connector |
|
JSON |
Apache Kafka connector, Upsert Kafka connector, Elasticsearch connector, OSS connector, ApsaraDB for MongoDB connector, and StarRocks connector |
|
Canal |
Apache Kafka connector and OSS connector |
|
Debezium |
Apache Kafka connector and OSS connector |
|
Maxwell |
Apache Kafka connector and OSS connector |
|
CSV |
Apache Kafka connector, Upsert Kafka connector, ApsaraMQ for RocketMQ connector, StarRocks connector, and OSS connector |
|
Avro |
Apache Kafka connector, Upsert Kafka connector, and OSS connector |
|
Confluent Avro |
Apache Kafka connector and Upsert Kafka connector |
|
Raw |
Apache Kafka connector, Upsert Kafka connector, and OSS connector |
|
Parquet |
OSS connector, which is used in Realtime Compute for Apache Flink that uses Ververica Runtime (VVR) 6.0.7 or later |