Make debezium.sink.iceberg.table-prefix optional (#212)

memiiso · Jun 13, 2023 · 9286294 · 9286294
1 parent f28ce7e
commit 9286294
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...m-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeConsumer.java b/...m-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeConsumer.java
@@ -88,7 +88,7 @@ public class IcebergChangeConsumer extends BaseChangeConsumer implements Debeziu
   @ConfigProperty(name = "debezium.sink.iceberg.destination-regexp-replace", defaultValue = "")
   protected Optional<String> destinationRegexpReplace;
   @ConfigProperty(name = "debezium.sink.iceberg.table-prefix", defaultValue = "")
-  String tablePrefix;
+  Optional<String> tablePrefix;
   @ConfigProperty(name = "debezium.sink.iceberg.table-namespace", defaultValue = "default")
   String namespace;
   @ConfigProperty(name = "debezium.sink.iceberg.catalog-name", defaultValue = "default")
@@ -213,6 +213,6 @@ public TableIdentifier mapDestination(String destination) {
         .replaceAll(destinationRegexp.orElse(""), destinationRegexpReplace.orElse(""))
         .replace(".", "_");
 
-    return TableIdentifier.of(Namespace.of(namespace), tablePrefix + tableName);
+    return TableIdentifier.of(Namespace.of(namespace), tablePrefix.orElse("") + tableName);
   }
 }