如何为JDBC Sink配置动态表名大写转换 实现Postgres到Oracle CDC同步

• 原生RegexRouter不支持直接对捕获占位符做大小写转换。你想通过TEST.$3的配置自动把$3捕获的小写表名转大写，靠Kafka自带的原生RegexRouter无法实现：其替换逻辑仅支持直接引用正则捕获组，没有内置的大小写转换函数能力，最终生成的目标表名会是和源端一致的小写形式TEST.dummy_table。
• 你遇到的双引号包裹表名的报错，本质是quote.sql.identifiers: never的配置存在版本兼容问题：当JDBC Sink检测到传入的SQL标识符包含小写字符时，部分旧版本连接器会强制绕开配置，给标识符自动加双引号。而Oracle对带双引号的标识符是严格大小写敏感匹配的，自然找不到小写命名的dummy_table，抛出“表不存在”的错误。

方案1：用JDBC Sink原生table.name.format动态生成全大写表名（推荐） #

Confluent JDBC Sink Connector 6.2及以上版本，完全不需要硬编码表名，也不需要额外的路由SMT，直接靠内置的表名格式化能力就能实现动态大写映射：

1. 删除原有硬编码的transforms.route相关配置，因为table.name.format可以完全覆盖路由表名的能力
2. 直接配置table.name.format规则，从Debezium生成的标准topic名（格式为源端逻辑名.库schema名.表名，比如你的test.public.dummy_table）中提取表名部分，强制转大写后拼接为Oracle的目标表名：

   "table.name.format": "TEST.${upper(regex: {topic}, '^[^.]+\\.[^.]+\\.([^.]+)$', '$1')}"
   

3. 保留原有quote.sql.identifiers: never配置即可
   该方案下，每新增一张同步表，只需要把对应的Debezium topic加入连接器的topics配置列表，不需要单独创建连接器，也不需要维护硬编码的表名映射，完全满足动态配置的需求。

方案2：低版本连接器适配方案 #

如果你使用的JDBC Sink版本低于6.2，无法使用table.name.format的内置函数能力，可以用Confluent生态扩展版的RegexRouter（Confluent从5.0版本开始对原生RegexRouter做了扩展，支持捕获组的大小写转换），在原有转换链上调整配置即可，不需要硬编码单表名：

1. 调整转换链顺序为unwrap,upperCaseTable,route，保留原有的Debezium状态解包逻辑
2. 新增大小写转换的路由规则，先把捕获到的小写表名转大写，再做Schema映射：

   "transforms": "unwrap,upperCaseTable,route",
   "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
   "transforms.unwrap.drop.tombstones": "false",
   "transforms.upperCaseTable.type": "io.confluent.connect.transforms.RegexRouter",
   // 从原始topic中捕获第三段的小写表名，转大写后重写topic名
   "transforms.upperCaseTable.regex": "^[^.]+\\.[^.]+\\.([a-z0-9_]+)$",
   "transforms.upperCaseTable.replacement": "test.public.${upper($1)}",
   "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter",
   // 因为上一步已经把表名转成大写了，这里直接做Schema映射，不需要硬编码表名
   "transforms.route.regex": "^[^.]+\\.[^.]+\\.([^.]+)$",
   "transforms.route.replacement": "TEST.$1"
   

方案3：引号问题兜底规避 #

如果不想调整转换逻辑，只要确保连接器传给Oracle的SQL语句中，表名是不带引号的全大写形式，就不会触发强制加双引号的问题：

• 检查JDBC连接URL配置，确保Oracle驱动会对不带引号的标识符自动转大写执行（这是Oracle驱动的默认行为，不需要额外改）
• 不要给目标表名传入小写字符，哪怕是通过动态规则生成，只要最终传入连接器的表名是全大写的，quote.sql.identifiers: never的配置就会正常生效，不会给标识符加双引号。

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