diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/offset/IcebergOffsetBackingStore.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/offset/IcebergOffsetBackingStore.java index f6d1e639..f9d945af 100644 --- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/offset/IcebergOffsetBackingStore.java +++ b/debezium-server-iceberg-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> 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 index e213e1e0..881a9f24 100644 --- a/pom.xml +++ b/pom.xml @@ -37,12 +37,12 @@ 2.19.4 1.19.0 - 2.2.1.Final + 2.4.0.CR1 8.0.32 3.3.2 - 4.8 + 4.9.3