diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeConsumer.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeConsumer.java index b5c668f8..a4f77e8e 100644 --- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergChangeConsumer.java +++ b/debezium-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 destinationRegexpReplace; @ConfigProperty(name = "debezium.sink.iceberg.table-prefix", defaultValue = "") - String tablePrefix; + Optional 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); } }