Upgrade debezium version to 2.4.x (#235)

* Upgrade debezium to 2.4.x * Fix related debezium/debezium#4617
memiiso · Sep 30, 2023 · 99a7959 · 99a7959
1 parent bf39597
commit 99a7959
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/...eberg-sink/src/main/java/io/debezium/server/iceberg/offset/IcebergOffsetBackingStore.java b/...eberg-sink/src/main/java/io/debezium/server/iceberg/offset/IcebergOffsetBackingStore.java
@@ -241,6 +241,10 @@ public static ByteBuffer toByteBuffer(String data) {
     return (data != null) ? ByteBuffer.wrap(data.getBytes(StandardCharsets.UTF_8)) : null;
   }
 
+  public Set<Map<String, Object>> connectorPartitions(String connectorName) {
+    return null;
+  }
+
   public static class IcebergOffsetBackingStoreConfig extends WorkerConfig {
     final org.apache.hadoop.conf.Configuration hadoopConfig = new org.apache.hadoop.conf.Configuration();
     private final Configuration config;

diff --git a/pom.xml b/pom.xml
@@ -37,12 +37,12 @@
         <version.awssdk>2.19.4</version.awssdk>
         <version.testcontainers>1.19.0</version.testcontainers>
         <!-- Debezium -->
-        <version.debezium>2.2.1.Final</version.debezium>
+        <version.debezium>2.4.0.CR1</version.debezium>
         <version.mysql.driver>8.0.32</version.mysql.driver>
         <!-- Quarkus -->
         <version.quarkus>3.3.2</version.quarkus>
         <!-- FOR TESTS Align with SPARK Antlr version -->
-        <version.antlr>4.8</version.antlr>
+        <version.antlr>4.9.3</version.antlr>
     </properties>
     <repositories>
         <repository>