[camel-examples] 21/35: Camel-AWS S3 Streaming upload: Use useDefaultCredentialProvider

[dfoulks]

This is an automated email from the ASF dual-hosted git repository.

dfoulks pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-examples.git

commit a4c9db5225fa7f56d2dfd1026b21ca60f5327fa1
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Apr 13 14:26:51 2021 +0200

    Camel-AWS S3 Streaming upload: Use useDefaultCredentialProvider
---
 .../src/main/java/org/apache/camel/example/MyRouteBuilder.java        | 4 ++--
 .../src/main/resources/application.properties                         | 3 ---
 2 files changed, 2 insertions(+), 5 deletions(-)

diff --git 
a/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
 
b/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
index 29c5b0f..32f0a7f 100644
--- 
a/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
+++ 
b/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
@@ -28,10 +28,10 @@ public class MyRouteBuilder extends EndpointRouteBuilder {
         
         from(kafka("{{kafkaTopic1}}").brokers("{{kafkaBrokers}}"))
               .log("Kafka Message is: ${body}")
-              
.to(aws2S3("{{bucketName}}").streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
+              
.to(aws2S3("{{bucketName}}").useDefaultCredentialsProvider(true).streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
 
         from(kafka("{{kafkaTopic2}}").brokers("{{kafkaBrokers}}"))
                 .log("Kafka Message is: ${body}")
-                
.to(aws2S3("{{bucketName}}").streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
+                
.to(aws2S3("{{bucketName}}").useDefaultCredentialsProvider(true).streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
     }
 }
diff --git 
a/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/resources/application.properties
 
b/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/resources/application.properties
index 2e654d0..1e4c766 100644
--- 
a/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/resources/application.properties
+++ 
b/examples/aws/main-endpointdsl-kafka-aws2-s3/src/main/resources/application.properties
@@ -20,9 +20,6 @@
 camel.main.name = Kafka-to-AWS2-S3-Stream
 
 # properties used in the route
-camel.component.aws2-s3.accessKey=xxxxx
-camel.component.aws2-s3.secretKey=yyyyy
-camel.component.aws2-s3.region=region
 bucketName=camel-1
 
 kafkaTopic1=s3.topic.1