From 37c87f35780174df2b21020adf39e119bc6506c8 Mon Sep 17 00:00:00 2001 From: Eric Fu Date: Mon, 4 Mar 2024 16:27:21 +0800 Subject: [PATCH] fix(cdc-connector): allow empty passwords --- .../com/risingwave/connector/source/SourceValidateHandler.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/SourceValidateHandler.java b/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/SourceValidateHandler.java index d6afb17fb0ccf..23611495c6077 100644 --- a/java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/source/SourceValidateHandler.java +++ b/java/connector-node/risingwave-connector-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 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 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);