2

我有一个配置了 MongoDB Kafka 连接器 v1.3 output.json.formatter=com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson,所以我的 UUID 字段输出如下"_id":"MSRJCs07SFy4sMpopdRvEA=="

但是,该 Kafka 消息的一个客户端需要将该 SimplifiedJson 转换为有效的 ExtendedJson,并从该 ExtendedJson 实例化一个 org.bson.BsonDocument(mongodb Java SDK),因此 _id 应该被识别为具有值的 BsonBinary(UUID) 3124490a-cd3b-485c-b8b0-ca68a5d46f10。

直接从 SimplifiedJson 尝试 BsonDocument.parse,该值"_id":"MSRJCs07SFy4sMpopdRvEA=="被视为 BsonString。

客户端无法手动执行此操作,因为该字段没有标准,可能是对象 id、uuid 或任何其他对生成该数据的应用程序有意义的东西。

那么,MongoDB 库中是否有任何内置方法可以将 SimplifiedJson 转换为具有相同原始字段类型(对象 id、二进制、日期、数字等)的 Bson?

4

0 回答 0