Skip to content

Commit 065737c

Browse files
committed
Ensure operations are ordered
KAFKA-37
1 parent 23e0881 commit 065737c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/mongodb/kafka/connect/sink/MongoSinkTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@
6363

6464
public class MongoSinkTask extends SinkTask {
6565
private static final Logger LOGGER = LoggerFactory.getLogger(MongoSinkTask.class);
66-
private static final BulkWriteOptions BULK_WRITE_OPTIONS = new BulkWriteOptions().ordered(false); // TODO keep the order?
66+
private static final BulkWriteOptions BULK_WRITE_OPTIONS = new BulkWriteOptions();
6767

6868
private MongoSinkConfig sinkConfig;
6969
private MongoClient mongoClient;

0 commit comments

Comments
 (0)