This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit fbb21c33f1e343fdef527fbd0aa3a39bd9ae8ccf Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Jun 19 11:32:15 2023 +0200 CAMEL-19159 - Camel-AWS: Support Profile Credential provider as configuration - AWS MSK Signed-off-by: Andrea Cosentino <[email protected]> --- .../component/aws2/msk/MSK2Configuration.java | 26 ++++++++++++++++++++++ 1 file changed, 26 insertions(+) diff --git a/components/camel-aws/camel-aws2-msk/src/main/java/org/apache/camel/component/aws2/msk/MSK2Configuration.java b/components/camel-aws/camel-aws2-msk/src/main/java/org/apache/camel/component/aws2/msk/MSK2Configuration.java index cb15cfc98b1..61b51c03f40 100644 --- a/components/camel-aws/camel-aws2-msk/src/main/java/org/apache/camel/component/aws2/msk/MSK2Configuration.java +++ b/components/camel-aws/camel-aws2-msk/src/main/java/org/apache/camel/component/aws2/msk/MSK2Configuration.java @@ -58,6 +58,10 @@ public class MSK2Configuration implements Cloneable { private String uriEndpointOverride; @UriParam(defaultValue = "false") private boolean useDefaultCredentialsProvider; + @UriParam(defaultValue = "false") + private boolean useProfileCredentialsProvider; + @UriParam + private String profileCredentialsName; public KafkaClient getMskClient() { return mskClient; @@ -204,6 +208,28 @@ public class MSK2Configuration implements Cloneable { public Boolean isUseDefaultCredentialsProvider() { return useDefaultCredentialsProvider; } + + public boolean isUseProfileCredentialsProvider() { + return useProfileCredentialsProvider; + } + + /** + * Set whether the MSK client should expect to load credentials through a profile credentials provider. + */ + public void setUseProfileCredentialsProvider(boolean useProfileCredentialsProvider) { + this.useProfileCredentialsProvider = useProfileCredentialsProvider; + } + + public String getProfileCredentialsName() { + return profileCredentialsName; + } + + /** + * If using a profile credentials provider this parameter will set the profile name + */ + public void setProfileCredentialsName(String profileCredentialsName) { + this.profileCredentialsName = profileCredentialsName; + } // ************************************************* // // *************************************************
