DBZ-8129 change check for "secure" so it takes value of JdbcConfig in…

…stead of default value in from As400ConnectorConfig
jhc-systems · Aug 23, 2024 · 437be80 · 437be80
1 parent 5372c44
commit 437be80
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/debezium-connector-ibmi/src/main/java/io/debezium/connector/db2as400/As400RpcConnection.java b/debezium-connector-ibmi/src/main/java/io/debezium/connector/db2as400/As400RpcConnection.java
@@ -50,7 +50,7 @@ public class As400RpcConnection implements AutoCloseable, Connect<AS400, IOExcep
     public As400RpcConnection(As400ConnectorConfig config, As400StreamingChangeEventSourceMetrics streamingMetrics, List<FileFilter> includes) {
         super();
         this.config = config;
-        this.isSecure = config.isSecure();
+        this.isSecure = config.getJdbcConfig().getBoolean("secure", config.isSecure());
         this.streamingMetrics = streamingMetrics;
         try {
             System.setProperty("com.ibm.as400.access.AS400.guiAvailable", "False");