Flink CdcTools 使用Oracle XStream方式 初始化时无问题,在增量同步时无法识别Oracle Date类型数据,会将目标字段值设为NULL

Viewed 34

AI给出结论:
XStream 走的是二进制 LCR(Logical Change Record),Oracle DATE 存储为 7 字节格式(不是标准 JDBC TIMESTAMP),需要 Connector 端解码。
一些 FlinkCDC 版本对 DATE → TIMESTAMP 的解码缺失,导致 Debezium 直接丢 null 给下游

1 Answers

可以使用logminer的方式试试