You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/04/06 09:51:25 UTC
[camel-examples] 01/02: CAMEL-16185 - AWS S3: improve multipart
support - streaming upload
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git
commit 2e9b6ff94b57b8393c541fc80200a8803fec618a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Apr 6 11:08:34 2021 +0200
CAMEL-16185 - AWS S3: improve multipart support - streaming upload
---
.../src/main/java/org/apache/camel/example/MyRouteBuilder.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/examples/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java b/examples/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
index d46ed3a..5178a22 100644
--- a/examples/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
+++ b/examples/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}}").streamMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
+ .to(aws2S3("{{bucketName}}").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}}").streamMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
+ .to(aws2S3("{{bucketName}}").streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
}
}