There was an error while loading. Please reload this page.
1 parent 6aca2c5 commit 23011e9Copy full SHA for 23011e9
1 file changed
lib/change_stream.js
@@ -149,6 +149,7 @@ var buildChangeStreamAggregationCommand = function (serverConfig, namespace, pip
149
var command = {
150
aggregate : namespace.collection,
151
pipeline : changeStreamPipeline,
152
+ readConcern: { level: 'majority' },
153
cursor: {
154
batchSize: options.batchSize || 1
155
}
0 commit comments