diff --git a/debezium-server-core/src/main/java/io/debezium/server/DebeziumServer.java b/debezium-server-core/src/main/java/io/debezium/server/DebeziumServer.java index c218ec84..74e04f3c 100644 --- a/debezium-server-core/src/main/java/io/debezium/server/DebeziumServer.java +++ b/debezium-server-core/src/main/java/io/debezium/server/DebeziumServer.java @@ -193,7 +193,7 @@ private void configToProperties(Config config, Properties props, String oldPrefi if (updatedPropertyName != null && updatedPropertyName.startsWith(oldPrefix)) { String finalPropertyName = newPrefix + updatedPropertyName.substring(oldPrefix.length()); if (overwrite || !props.containsKey(finalPropertyName)) { - props.setProperty(finalPropertyName, config.getValue(name, String.class)); + props.setProperty(finalPropertyName, config.getOptionalValue(name, String.class).orElse("")); } } else if (name.startsWith(oldPrefix)) {