-
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]:优化调整重复代码
| Name |
Last commit
|
Last update |
|---|---|---|
| .. | ||
| doris | ||
| kafka | ||
| mysql | ||
| oracle | ||
| sql | ||
| starrocks | ||
| AbstractCDCBuilder.java | ||
| AbstractSinkBuilder.java | ||
| CDCBuilder.java | ||
| CDCBuilderFactory.java | ||
| SinkBuilder.java | ||
| SinkBuilderFactory.java |