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 c4b8d4489e1e8167da65cb1375290d97dda4d465 Author: Andrea Cosentino <[email protected]> AuthorDate: Fri Sep 10 14:46:36 2021 +0200 Regen --- docs/components/modules/ROOT/pages/aws2-s3-component.adoc | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/docs/components/modules/ROOT/pages/aws2-s3-component.adoc b/docs/components/modules/ROOT/pages/aws2-s3-component.adoc index 6adbbc6..d3fa619 100644 --- a/docs/components/modules/ROOT/pages/aws2-s3-component.adoc +++ b/docs/components/modules/ROOT/pages/aws2-s3-component.adoc @@ -631,6 +631,20 @@ Setting the header means potentially change the file name on each exchange and t The selected naming strategy will do the rest of the of the work. ==== +Another possibility is specifying a streamingUploadTimeout with batchMessageNumber and batchSize options. With this option the user will be able to complete the upload of a file after a certain time passed. +In this way the upload completion will be passed on three tiers: the timeout, the number of messages and the batch size. + +As an example: + +[source,java] +-------------------------------------------------------------------------------- +from(kafka("topic1").brokers("localhost:9092")) + .log("Kafka Message is: ${body}") + .to(aws2S3("camel-bucket").streamingUploadMode(true).batchMessageNumber(25).streamingUploadTimeout(10000).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt")); +-------------------------------------------------------------------------------- + +In this case the upload will be completed after 10 seconds. + == Bucket Autocreation With the option `autoCreateBucket` users are able to avoid the autocreation of an S3 Bucket in case it doesn't exist. The default for this option is `true`.
