Spring Data MongoDB的save()方法触发MongoDB Change Streams的行为疑问

• 结论：是的，Spring Data MongoDB的save()方法在执行更新操作时，会被MongoDB Change Streams判定为replace事件。
• 底层逻辑：Spring Data的save()方法会根据实体是否存在（通过ID判断）执行不同操作：
  • 若实体为新对象（无ID或ID未在数据库中找到）：执行插入（insert）操作；
  • 若实体已存在：底层默认调用MongoDB的replaceOne()命令，用传入的完整实体文档替换数据库中的原文档，而非仅更新变化的字段。
• 对应现象：这也是你从oplog中看不到增量更新的原因——save()的更新本质是全文档替换，符合MongoDB中replace事件的触发条件（由replaceOne类操作触发），所以Change Streams会捕获为replace事件，进而导致Kafka源连接器产生大量这类事件，增加数据处理量。

优化建议 #

如果想减少replace事件、实现增量更新，可以：

• 使用update()方法配合MongoDB更新操作符（如$set），仅指定需要修改的字段；
• 对于Spring Data MongoDB 3.0及以上版本，可通过@Document(updateStrategy = UpdateStrategy.UPDATE)注解配置实体的更新策略，强制使用增量更新而非替换；
• 自定义更新查询，精准控制更新字段和逻辑。

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