-
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]:优化调整重复代码