Kafka Oracle JDBC Connector数字时间戳适配问题求助

方案1：自定义查询语句（最直接有效） #

由于你只有数据库只读权限，无法修改表结构，自定义查询是最可靠的解决方式。核心思路是在查询中同时处理列的类型转换和增量参数的类型转换，让WHERE子句两边的类型完全匹配。

示例配置 #

connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:oracle:thin:@//your-db-host:1521/your-sid
connection.user=readonly-user
connection.password=your-password
# 使用timestamp模式，指定转换后的列作为增量追踪列
mode=timestamp
timestamp.column.name=LAST_UPDATE_DATE_TIMESTAMP
# 自定义查询：转换原NUMBER列为TIMESTAMP，同时将连接器传入的TIMESTAMP参数转成NUMBER格式
query=SELECT \
    t.*, \
    TO_TIMESTAMP(TO_CHAR(t.LAST_UPDATE_DATE, 'YYYYMMDDHH24MISSFF3'), 'YYYYMMDDHH24MISSFF3') AS LAST_UPDATE_DATE_TIMESTAMP \
FROM your_table t \
WHERE TO_NUMBER(TO_CHAR(?,'YYYYMMDDHH24MISSFF3')) <= t.LAST_UPDATE_DATE
# 若原NUMBER列允许为空，关闭非空校验
validate.non.null=false

关键细节 #

• 原NUMBER列格式20221220145930000对应格式符YYYYMMDDHH24MISSFF3（前8位是日期，中间6位是时分秒，最后3位是毫秒），如果你的数据没有毫秒部分，直接改成YYYYMMDDHH24MISS即可。
• ?是Kafka Connect自动传入的增量时间戳参数，通过TO_CHAR(?,'格式')转成字符串再转成NUMBER，和原列类型完全匹配，彻底避免ORA-00932类型不匹配错误。
• timestamp.column.name指定转换后的TIMESTAMP列，让连接器能正确追踪增量同步的位置。

为什么之前的尝试无效？ #

• 仅在SELECT中用TO_TIMESTAMP()：连接器仍会使用原NUMBER列生成WHERE子句，导致TIMESTAMP类型的参数和NUMBER类型的列直接比较，触发类型错误。
• TimestampConverter SMT：这个转换是在数据读取完成后对消息值进行格式转换，无法修改连接器生成的WHERE子句的参数类型，因此解决不了查询阶段的类型不匹配问题。

内容的提问来源于stack exchange，提问作者Schuji