flink cdc 将binlog日志反序列化成sql语句_flinkcdc如何转化为sql-CSDN博客

网站介绍:文章浏览阅读661次,点赞3次,收藏6次。package com.ysservice.streaming.source;import com.alibaba.ververica.cdc.debezium.DebeziumDeserializationSchema;import com.ysservice.streaming.utils.MysqlUtil;import com.ysservice.streaming.utils.SystemConstants;import io.debezium.data.Envelope;import_flinkcdc如何转化为sql