Debezium同步PostgreSQL分区表至MongoDB时序集合失败求助

核心问题确认 #

MongoDB时序集合不支持带upsert: true的更新操作，而Debezium MongoDB Sink连接器默认启用了upsert逻辑，这是导致同步失败的直接原因。以下是针对性的解决方案：

方案1：切换为纯插入模式（适用于只追加的时序数据） #

修改Sink连接器配置，将插入模式从默认的upsert改为insert，彻底避免触发upsert操作：

insert.mode=insert

注意：如果源PostgreSQL表存在更新/删除操作，这些操作会同步失败（因为时序集合不允许修改已有文档）。如果你的数据是日志、监控这类只追加的时序数据，这个方案最直接有效。

方案2：将所有变更转为新文档插入（保留更新记录） #

如果需要保留更新操作的历史（把更新事件转为新的时序文档），可以禁用自定义文档ID生成，让MongoDB自动生成新的_id，确保每个CDC事件都作为新文档插入：

document.id.strategy=none
insert.mode=insert

方案3：过滤更新/删除事件（只同步插入操作） #

如果业务只需要同步PostgreSQL的插入事件，忽略更新和删除，用Debezium的Filter transform过滤非插入事件：

transforms=filterInserts
transforms.filterInserts.type=io.debezium.transforms.Filter
transforms.filterInserts.language=jsr223.groovy
transforms.filterInserts.condition=value.op == 'c'

这里value.op == 'c'表示仅保留创建（插入）事件，u（更新）、d（删除）事件会被过滤。

额外检查项 #

确保MongoDB时序集合的基础配置正确：

• 已指定timeField，且该字段与PostgreSQL的时间戳分区字段对应
• 同步的文档中包含合法的时间字段值
• 时序集合未开启允许修改已有文档的特殊配置

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