Fix related debezium/debezium#4617

memiiso · Sep 30, 2023 · ac4beec · ac4beec
1 parent 409bdac
commit ac4beec
Showing 1 changed file with 4 additions and 0 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;