如何在 change stream watch api (mongo-go-driver) 中设置 batchSize？
How to set batchSize in change stream watch api (mongo-go-driver)?
我正在使用 changestreamopt.BatchSize 传递 batchSize。
但这不起作用发生此错误：BSON field '$changeStream.batchSize' is an unknown field
样本API调用
// coll is *mongo.Collection
// ctx is context
cur, err := coll.Watch(ctx, nil, changestreamopt.BatchSize(1000))
这看起来像是当前 mongo-go-driver (v0.0.16) 中的错误，其中 batchSize 选项被传递到 $changestream 管道阶段而不是游标。
代码change_stream.go#L66-L73似乎只对光标使用maxAwaitTime。
我已经和 MongoDB Go driver 团队开了一张票 GODRIVER-591。
我正在使用 changestreamopt.BatchSize 传递 batchSize。
但这不起作用发生此错误：BSON field '$changeStream.batchSize' is an unknown field
样本API调用
// coll is *mongo.Collection
// ctx is context
cur, err := coll.Watch(ctx, nil, changestreamopt.BatchSize(1000))
这看起来像是当前 mongo-go-driver (v0.0.16) 中的错误，其中 batchSize 选项被传递到 $changestream 管道阶段而不是游标。
代码change_stream.go#L66-L73似乎只对光标使用maxAwaitTime。
我已经和 MongoDB Go driver 团队开了一张票 GODRIVER-591。