MongoJava驱动程序3.6：更改流编解码器错误

Question

我正在尝试使用MongoJava驱动程序3.6的新更改流功能，但我卡住了。这是我的错误：

ChangeStreamDocument contains generic types that have not been specialised.
Top level classes with generic types are not supported by the PojoCodec.

下面是我启动changeStream的方法：

CodecRegistry pojoCodecRegistry = fromRegistries(MongoClient.getDefaultCodecRegistry(),
        fromProviders(PojoCodecProvider.builder().automatic(true).build()));

MongoDatabase database = mongoClient.getDatabase(mongoClientURI.getDatabase())
                                    .withCodecRegistry(pojoCodecRegistry);

collection.insertOne(Person.builder().age(100).build());
collection.insertOne(Person.builder().age(100).build());
collection.watch().forEach((Block<? super ChangeStreamDocument<Person>>) personChangeStreamDocument -> {
    System.out.println(personChangeStreamDocument.getFullDocument());
});

< code>Person只是一个POJO。

Answer 1

JAVA-2800中描述的自动< code > projocodeprovider 目前有一个错误。

临时解决方法是手动注册 POJO 类，例如：

CodecRegistry pojoCodecRegistry = fromRegistries(MongoClient.getDefaultCodecRegistry(),
                                 fromProviders(PojoCodecProvider.builder().register(Person.class).build())); 

此外，请注意，如果在打开集合上的更改流之前执行了插入操作，您可能看不到事件插入。尽管您可以通过从另一个线程或进程插入/修改文档来轻松测试这一点。请参见更改流了解详情。

更新：票证JAVA-2800已解决，MongoDB Java驱动程序v3.6.4上提供了修复版本。