diff --git a/build.gradle.kts b/build.gradle.kts
index ee63976c..0fca9732 100644
--- a/build.gradle.kts
+++ b/build.gradle.kts
@@ -50,7 +50,7 @@ repositories {
 
 extra.apply {
     set("mongodbDriverVersion", "[4.7,4.7.99)")
-    set("kafkaVersion", "2.6.0")
+    set("kafkaVersion", "3.4.0")
     set("avroVersion", "1.9.2")
 
     // Testing dependencies
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;
+  }
 }