From 6deb32601360db8044f8f559202166308f4a49d4 Mon Sep 17 00:00:00 2001
From: Tyson Mote <tmote@rippling.com>
Date: Sat, 5 Aug 2023 12:45:21 -0700
Subject: [PATCH] MongoSourceConnector: Indicate exactly-once support

---
 .../com/mongodb/kafka/connect/MongoSourceConnector.java     | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/main/java/com/mongodb/kafka/connect/MongoSourceConnector.java b/src/main/java/com/mongodb/kafka/connect/MongoSourceConnector.java
index a6e624c5..44d02f39 100644
--- a/src/main/java/com/mongodb/kafka/connect/MongoSourceConnector.java
+++ b/src/main/java/com/mongodb/kafka/connect/MongoSourceConnector.java
@@ -28,6 +28,7 @@
 import org.apache.kafka.common.config.Config;
 import org.apache.kafka.common.config.ConfigDef;
 import org.apache.kafka.connect.connector.Task;
+import org.apache.kafka.connect.source.ExactlyOnceSupport;
 import org.apache.kafka.connect.source.SourceConnector;
 
 import com.mongodb.kafka.connect.source.MongoSourceConfig;
@@ -100,4 +101,9 @@ public ConfigDef config() {
   public String version() {
     return Versions.VERSION;
   }
+
+  @Override
+  public ExactlyOnceSupport exactlyOnceSupport(final Map<String, String> connectorConfig) {
+    return ExactlyOnceSupport.SUPPORTED;
+  }
 }