尝试了canal-json,发现canal-json的decimal是不丢失精度的,4种事件类型的值,也符合期望
但是canal-json和debezium的数据结构不一样,flink层做结构适配,或者结构转换
携带的信息也各有优劣,但是核心信息都是有的。
目前计划采用canal-json格式,不使用debezium,打算基于一个flink程序,同时兼容两种数据格式的转换,由于历史很多程序都是基于debezium格式做的,因此在数据转换的源头程序flink种,尝试将canal-json的结构粗略转换为debezium的结构,降低下游程序的数据结构适配。