Package org.apache.flink.cdc.connectors.kafka.json.canal

Class Summary

Class	Description
CanalJsonSerializationSchema	Serialization schema that serializes an object of FlinkCDC pipeline internal data structure Event into a Canal JSON bytes.