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 b8708c23718a791c94074d4f03e54322313968fb Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Tue Apr 6 11:50:02 2021 +0200 Fixed example --- .../src/main/java/org/apache/camel/example/MyRouteBuilder.java | 4 ++-- .../src/main/resources/application.properties | 4 ++-- 2 files changed, 4 insertions(+), 4 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 5178a22..29c5b0f 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 @@ -27,8 +27,8 @@ 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")); + .log("Kafka Message is: ${body}") + .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}") diff --git a/examples/main-endpointdsl-kafka-aws2-s3/src/main/resources/application.properties b/examples/main-endpointdsl-kafka-aws2-s3/src/main/resources/application.properties index 2ae5fc7..2e654d0 100644 --- a/examples/main-endpointdsl-kafka-aws2-s3/src/main/resources/application.properties +++ b/examples/main-endpointdsl-kafka-aws2-s3/src/main/resources/application.properties @@ -21,9 +21,9 @@ camel.main.name = Kafka-to-AWS2-S3-Stream # properties used in the route camel.component.aws2-s3.accessKey=xxxxx -camel.component.aws2-s3.secretKey=yyyy +camel.component.aws2-s3.secretKey=yyyyy camel.component.aws2-s3.region=region -bucketName=mycamel-1 +bucketName=camel-1 kafkaTopic1=s3.topic.1 kafkaTopic2=s3.topic.2