Как установить batchSize в api потока изменений (mongo-go-driver)?

Question

Я передаю batchSize, используя changestreamopt.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))

Answer 1

Это похоже на ошибку в текущем mongo-go-driver (v0.0.16), где опция batchSize передается на стадию $changestream конвейера вместо курсора.

Код change_stream.go # L66-L73 , кажется, использует только maxAwaitTime для курсора.

Я открыл билет GODRIVER-591 с командой водителей MongoDB Go.