use local cdk

sendinblue · Mar 28, 2024 · e6ff9c3 · e6ff9c3
1 parent 03efd15
commit e6ff9c3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ngodb-v2/src/main/java/io/airbyte/integrations/source/mongodb/InitialSnapshotHandler.java b/...ngodb-v2/src/main/java/io/airbyte/integrations/source/mongodb/InitialSnapshotHandler.java
@@ -4,6 +4,7 @@
 
 package io.airbyte.integrations.source.mongodb;
 
+import com.mongodb.ReadConcern;
 import com.mongodb.client.MongoCollection;
 import com.mongodb.client.MongoDatabase;
 import com.mongodb.client.model.*;
@@ -50,7 +51,7 @@ public List<AutoCloseableIterator<AirbyteMessage>> getIterators(
         .stream()
         .map(airbyteStream -> {
           final var collectionName = airbyteStream.getStream().getName();
-          final var collection = database.getCollection(collectionName);
+          final var collection = database.getCollection(collectionName).withReadConcern(ReadConcern.LOCAL);
           final var fields = Projections.fields(Projections.include(CatalogHelpers.getTopLevelFieldNames(airbyteStream).stream().toList()));
 
           final var idTypes = aggregateIdField(collection);