MongoDB变更流中updateDescription.updatedFields为null的问题排查

嘿，我一眼就瞅出问题根源了——你遇到的updateDescription.updatedFields始终为null的核心原因，是你在变更流过滤条件里指定了operationType为replace！

MongoDB的replace操作是直接替换整个文档，这类变更事件根本不会生成updateDescription字段，自然也就没有updatedFields可以获取了。只有update类型的操作（也就是针对部分字段修改的操作），才会在变更事件里包含updateDescription，用来记录具体被更新的字段和值。

再看你的代码逻辑，你同时设置了几个冲突的过滤条件：既要求updateDescription.updatedFields.status存在，又限定操作类型是replace，这俩条件本身就矛盾，所以要么匹配不到事件，要么拿到的updateDescription就是null。

给你两个针对性的解决方案，看你实际业务场景选：

场景1：监听字段更新（比如status被修改） #

如果你的需求是监听status字段的更新操作，那把操作类型改成update，同时调整过滤条件，确保只捕获status被改成DONE或ERROR的事件：

MongoClient mongoClient = new MongoClient("localhost", 27017);
MongoDatabase database = mongoClient.getDatabase("db");
MongoCollection<org.bson.Document> collection = database.getCollection("collection");

// 修正后的聚合管道：只监听update操作，且status字段被更新为目标值
List<Bson> pipeline = Collections.singletonList(Aggregates.match(
    Filters.and(
        Filters.in("operationType", "update"),
        Filters.exists("updateDescription.updatedFields.status", true),
        Filters.or(
            Filters.eq("updateDescription.updatedFields.status", "DONE"),
            Filters.eq("updateDescription.updatedFields.status", "ERROR")
        )
    )
));

MongoCursor<ChangeStreamDocument<Document>> cursor = collection.watch(pipeline).iterator();

场景2：确实需要监听replace操作 #

如果你的业务里是用replace来更新文档，那就要放弃依赖updateDescription，直接从变更事件的fullDocument里获取最新的status值：

MongoClient mongoClient = new MongoClient("localhost", 27017);
MongoDatabase database = mongoClient.getDatabase("db");
MongoCollection<org.bson.Document> collection = database.getCollection("collection");

// 监听replace操作，直接从完整文档里判断status值
List<Bson> pipeline = Collections.singletonList(Aggregates.match(
    Filters.and(
        Filters.in("operationType", "replace"),
        Filters.in("fullDocument.status", "DONE", "ERROR")
    )
));

MongoCursor<ChangeStreamDocument<Document>> cursor = collection.watch(pipeline).iterator();

另外提一句，你用的MongoDB Java驱动版本3.6.3比较老旧了，虽然变更流功能在3.6已经支持，但新版本（比如4.x系列）修复了不少小问题，有条件的话建议升级一下，能避免一些潜在的兼容性坑。

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