From fb55712a11bcf13095aefe8c6d9270fb193d24b1 Mon Sep 17 00:00:00 2001
From: Tyson Mote <tmote@rippling.com>
Date: Sat, 5 Aug 2023 12:44:52 -0700
Subject: [PATCH 1/2] Bump Kafka to 3.4.0

---
 build.gradle.kts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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

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 2/2] 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;
+  }
 }