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:26 UTC
[camel-examples] 02/02: Fixed example
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 b8708c23718a791c94074d4f03e54322313968fb
Author: Andrea Cosentino <an...@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