paimon icon indicating copy to clipboard operation
paimon copied to clipboard

[cdc] Adjust-CdcJsonDeserializationSchema

Open MOBIN-F opened this issue 1 year ago • 0 comments

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.

Tests

API and Format

Documentation

MOBIN-F avatar Jul 17 '24 07:07 MOBIN-F