From a39a9ee64510bb7249815e1b722cf017d5447f24 Mon Sep 17 00:00:00 2001
From: Victor Garcia <vgarcia@thousandeyes.com>
Date: Tue, 30 Jul 2019 00:49:40 -0500
Subject: [PATCH] Ensuring order of bulk operations to avoid data loss or
 inconistent

---
 .../java/at/grahsl/kafka/connect/mongodb/MongoDbSinkTask.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/at/grahsl/kafka/connect/mongodb/MongoDbSinkTask.java b/src/main/java/at/grahsl/kafka/connect/mongodb/MongoDbSinkTask.java
index cb86f3e..d2b7f5f 100644
--- a/src/main/java/at/grahsl/kafka/connect/mongodb/MongoDbSinkTask.java
+++ b/src/main/java/at/grahsl/kafka/connect/mongodb/MongoDbSinkTask.java
@@ -51,7 +51,7 @@ public class MongoDbSinkTask extends SinkTask {
     private static Logger LOGGER = LoggerFactory.getLogger(MongoDbSinkTask.class);
 
     private static final BulkWriteOptions BULK_WRITE_OPTIONS =
-                            new BulkWriteOptions().ordered(false);
+                            new BulkWriteOptions().ordered(true);
 
     private MongoDbSinkConnectorConfig sinkConfig;
     private MongoClient mongoClient;