diff --git a/src/main/java/com/snowflake/kafka/connector/config/ConnectorConfigDefinition.java b/src/main/java/com/snowflake/kafka/connector/config/ConnectorConfigDefinition.java index e9823eab3..6d9820304 100644 --- a/src/main/java/com/snowflake/kafka/connector/config/ConnectorConfigDefinition.java +++ b/src/main/java/com/snowflake/kafka/connector/config/ConnectorConfigDefinition.java @@ -123,7 +123,7 @@ public static ConfigDef getConfig() { OAUTH_CLIENT_ID) .define( OAUTH_CLIENT_SECRET, - ConfigDef.Type.STRING, + ConfigDef.Type.PASSWORD, "", ConfigDef.Importance.HIGH, "Client secret of target OAuth integration", @@ -133,7 +133,7 @@ public static ConfigDef getConfig() { OAUTH_CLIENT_SECRET) .define( OAUTH_REFRESH_TOKEN, - ConfigDef.Type.STRING, + ConfigDef.Type.PASSWORD, "", ConfigDef.Importance.HIGH, "Refresh token for OAuth", @@ -184,7 +184,7 @@ public static ConfigDef getConfig() { JVM_PROXY_USERNAME) .define( JVM_PROXY_PASSWORD, - ConfigDef.Type.STRING, + ConfigDef.Type.PASSWORD, "", ConfigDef.Importance.LOW, "JVM proxy password",