|
@@ -18,12 +18,7 @@ public class PostgreSQLConfigChecker extends AbstractDataBaseConfigChecker {
|
|
|
super.modify(connectorConfig, params);
|
|
|
super.modifySchema(connectorConfig, params);
|
|
|
|
|
|
- String dropSlotOnClose = params.get("dropSlotOnClose");
|
|
|
- connectorConfig.getProperties().put("dropSlotOnClose", StringUtil.equals("on", dropSlotOnClose) ? "true" : "false");
|
|
|
-
|
|
|
- String pluginName = params.get("pluginName");
|
|
|
- if (StringUtil.isNotBlank(pluginName)) {
|
|
|
- connectorConfig.getProperties().put("pluginName", pluginName);
|
|
|
- }
|
|
|
+ connectorConfig.getProperties().put("dropSlotOnClose", StringUtil.isNotBlank(params.get("dropSlotOnClose")) ? "true" : "false");
|
|
|
+ connectorConfig.getProperties().put("pluginName", params.get("pluginName"));
|
|
|
}
|
|
|
}
|