MongoSourceConnector: Indicate exactly-once support

mongodb · Aug 5, 2023 · 6deb326 · 6deb326
1 parent fb55712
commit 6deb326
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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;
+  }
 }