Skip to content
This repository has been archived by the owner on Apr 1, 2024. It is now read-only.

Commit

Permalink
[improve] Make sslTruststorePassword sensitive for the Kafka connec…
Browse files Browse the repository at this point in the history
…tor config (apache#21639)

### Motivation

sslTruststorePassword value contains the sensitive passwords. We need to mark it as a sensitive configuration field.

### Modifications

- Make `sslTruststorePassword` sensitive for the Kafka connector config
  • Loading branch information
RobertIndie authored Nov 30, 2023
1 parent 7508700 commit 3377003
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -74,6 +74,7 @@ public class KafkaSinkConfig implements Serializable {

@FieldDoc(
defaultValue = "",
sensitive = true,
help = "The password for the trust store file.")
private String sslTruststorePassword;

Expand Down Expand Up @@ -126,4 +127,4 @@ public static KafkaSinkConfig load(Map<String, Object> map) throws IOException {
ObjectMapper mapper = new ObjectMapper();
return mapper.readValue(mapper.writeValueAsString(map), KafkaSinkConfig.class);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ public class KafkaSourceConfig implements Serializable {

@FieldDoc(
defaultValue = "",
sensitive = true,
help = "The password for the trust store file.")
private String sslTruststorePassword;

Expand Down Expand Up @@ -156,4 +157,4 @@ public static KafkaSourceConfig load(Map<String, Object> map) throws IOException
mapper.enable(DeserializationFeature.ACCEPT_EMPTY_STRING_AS_NULL_OBJECT);
return mapper.readValue(mapper.writeValueAsString(map), KafkaSourceConfig.class);
}
}
}

0 comments on commit 3377003

Please sign in to comment.