• 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
Name
Last commit
Last update
..
doris Loading commit data...
kafka Loading commit data...
mysql Loading commit data...
oracle Loading commit data...
sql Loading commit data...
starrocks Loading commit data...
AbstractCDCBuilder.java Loading commit data...
AbstractSinkBuilder.java Loading commit data...
CDCBuilder.java Loading commit data...
CDCBuilderFactory.java Loading commit data...
SinkBuilder.java Loading commit data...
SinkBuilderFactory.java Loading commit data...