paimon
paimon copied to clipboard
[cdc] Adjust-CdcJsonDeserializationSchema
Purpose
The serialization entry of cdc kafka_table/database_sync is CdcJsonDeserializationSchema, but CdcJsonDeserializationSchema#deserialize returns CdcSourceRecord(JsonNode). When users extend other format, there will be limitations. Most data serialization is based on byte[], not JsonNode. For example: Users need to use other serialization protocols to serialize data based on byte[], such as binlog of other databases.