• 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
.github Loading commit data...
.mvn/wrapper Loading commit data...
dlink-admin Loading commit data...
dlink-alert Loading commit data...
dlink-app Loading commit data...
dlink-assembly Loading commit data...
dlink-catalog Loading commit data...
dlink-client Loading commit data...
dlink-common Loading commit data...
dlink-connectors Loading commit data...
dlink-core Loading commit data...
dlink-daemon Loading commit data...
dlink-doc Loading commit data...
dlink-executor Loading commit data...
dlink-extends Loading commit data...
dlink-flink Loading commit data...
dlink-function Loading commit data...
dlink-gateway Loading commit data...
dlink-metadata Loading commit data...
dlink-web Loading commit data...
docker Loading commit data...
docs Loading commit data...
style Loading commit data...
.gitignore Loading commit data...
LICENSE Loading commit data...
README.md Loading commit data...
README_zh_CN.md Loading commit data...
build.cmd Loading commit data...
build.sh Loading commit data...
docker-compose.yaml Loading commit data...
mvnw Loading commit data...
mvnw.cmd Loading commit data...
pom.xml Loading commit data...