fix(cdc-connector): allow empty passwords

risingwavelabs · Mar 4, 2024 · 37c87f3 · 37c87f3
1 parent 0900c9f
commit 37c87f3
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...onnector-service/src/main/java/com/risingwave/connector/source/SourceValidateHandler.java b/...onnector-service/src/main/java/com/risingwave/connector/source/SourceValidateHandler.java
@@ -65,7 +65,7 @@ public static ConnectorServiceProto.ValidateSourceResponse validateResponse(Stri
     private static void ensurePropNotBlank(Map<String, String> props, String name) {
         if (StringUtils.isBlank(props.get(name))) {
             throw ValidatorUtils.invalidArgument(
-                    String.format("'%s' not found, please check the WITH properties", name));
+                    String.format("'%s' cannot be empty, please check the WITH properties", name));
         }
     }
 
@@ -74,7 +74,6 @@ static void ensureRequiredProps(Map<String, String> props, boolean isMultiTableS
         ensurePropNotBlank(props, DbzConnectorConfig.PORT);
         ensurePropNotBlank(props, DbzConnectorConfig.DB_NAME);
         ensurePropNotBlank(props, DbzConnectorConfig.USER);
-        ensurePropNotBlank(props, DbzConnectorConfig.PASSWORD);
         // ensure table name is passed by user in non-sharing mode
         if (!isMultiTableShared) {
             ensurePropNotBlank(props, DbzConnectorConfig.TABLE_NAME);