fix sslmode value

risingwavelabs · Nov 4, 2024 · ecba55d · ecba55d
1 parent 04755fd
commit ecba55d
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/...ctor-service/src/main/java/com/risingwave/connector/source/common/DbzConnectorConfig.java b/...ctor-service/src/main/java/com/risingwave/connector/source/common/DbzConnectorConfig.java
@@ -204,6 +204,23 @@ public DbzConnectorConfig(
                 }
             }
 
+            // adapt value of sslmode to the expected value
+            var sslMode = postgresProps.getProperty("database.sslmode");
+            if (sslMode != null) {
+                switch (sslMode) {
+                    case "disabled":
+                        sslMode = "disable";
+                        break;
+                    case "preferred":
+                        sslMode = "prefer";
+                        break;
+                    case "required":
+                        sslMode = "require";
+                        break;
+                }
+                postgresProps.setProperty("database.sslmode", sslMode);
+            }
+
             dbzProps.putAll(postgresProps);
 
             if (isCdcSourceJob) {