Package org.apache.flink.cdc.connectors.kafka.json.debezium
-
Class Summary Class Description DebeziumJsonRowDataSerializationSchema Serialization schema that serializes an object of Flink internal data structure into a JSON bytes.DebeziumJsonSerializationSchema Serialization schema from FlinkCDC pipeline internal data structureEventto Debezium JSON.DebeziumJsonStruct Debezium JSON struct.