• zhongjingq's avatar
    修复字符乱码和时区不正确以及增加datastream实现 (#845) · 20471f3d
    zhongjingq authored
    * fix: MYSQL CDC JsonDebeziumDeserializationSchema 字节转字符提定字符编码 UTF-8
    
    * fix: MYSQL CDC SQLSinkBuilder 转换mysql 类型datetime时,时区不正确,应该设置UTC实区
    
    * [Feature]:
       1:增加datastream-starrocks 实现,目前strrocks官网jar只到1.14对应的flink版本
       2:增加datastream-kafka-json 实现,主要实现抽像出必须的记录数据,增加扩展op、is_delete、schemaName,tableName,ts_ms等字段,方便业务使用
    
    * [optimization]:优化调整重复代码
    
    [optimization]:优化调整重复代码
    20471f3d
MysqlJsonDebeziumDeserializationSchema.java 2.29 KB