This topic describes the data formats supported by Realtime Compute for Apache Flink.
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 |