| commit | 4e424a7320d374ea27119b06013085738e2fc8b3 | [log] [tgz] |
|---|---|---|
| author | Andrea Cosentino <ancosen@gmail.com> | Tue Apr 13 14:49:12 2021 +0200 |
| committer | Andrea Cosentino <ancosen@gmail.com> | Tue Apr 13 14:49:12 2021 +0200 |
| tree | 01bb5a5f301e259e2cfca50ef6ce6f8d9767c72a | |
| parent | a4c9db5225fa7f56d2dfd1026b21ca60f5327fa1 [diff] |
Camel-AWS S3 Streaming upload: Use useDefaultCredentialProvider
diff --git a/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/java/org/apache/camel/example/MyRouteBuilder.java b/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/java/org/apache/camel/example/MyRouteBuilder.java index 29f739e..a3ed90d 100644 --- a/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/java/org/apache/camel/example/MyRouteBuilder.java +++ b/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/java/org/apache/camel/example/MyRouteBuilder.java
@@ -28,6 +28,6 @@ from(kafka("{{kafkaTopic1}}").brokers("{{kafkaBrokers}}")) .log("Kafka Message is: ${body}") - .toD(aws2S3("{{bucketName}}").streamingUploadMode(true).restartingPolicy(AWS2S3EndpointBuilderFactory.AWSS3RestartingPolicyEnum.lastPart).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/partition_${headers.kafka.PARTITION}/{{kafkaTopic1}}.txt")); + .toD(aws2S3("{{bucketName}}").streamingUploadMode(true).useDefaultCredentialsProvider(true).restartingPolicy(AWS2S3EndpointBuilderFactory.AWSS3RestartingPolicyEnum.lastPart).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/partition_${headers.kafka.PARTITION}/{{kafkaTopic1}}.txt")); } }
diff --git a/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/resources/application.properties b/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/resources/application.properties index 9a68e03..1bf3df7 100644 --- a/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/src/main/resources/application.properties +++ b/examples/aws/main-endpointdsl-kafka-aws2-s3-restarting-policy/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