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/01/11 12:40:31 UTC
[camel-kafka-connector-examples] 02/04: Aggregation on AWS2-S3
example: Fixed naming of camel.beans.aggregation options to
camel.aggregation for config files
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aws2-s3-sink-aggr
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git
commit 0ad34bcdd2fe10ee1d58795c584190e7cbbd1e3b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jan 11 13:34:41 2021 +0100
Aggregation on AWS2-S3 example: Fixed naming of camel.beans.aggregation options to camel.aggregation for config files
---
.../config/CamelAWS2S3SinkConnector.properties | 4 ++--
.../config/openshift/aws2-s3-sink-with-aggregation.yaml | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/aws2-s3/aws2-s3-sink-with-aggregation/config/CamelAWS2S3SinkConnector.properties b/aws2-s3/aws2-s3-sink-with-aggregation/config/CamelAWS2S3SinkConnector.properties
index 35ab39c..242a180 100644
--- a/aws2-s3/aws2-s3-sink-with-aggregation/config/CamelAWS2S3SinkConnector.properties
+++ b/aws2-s3/aws2-s3-sink-with-aggregation/config/CamelAWS2S3SinkConnector.properties
@@ -31,5 +31,5 @@ camel.component.aws2-s3.region=eu-west-1
camel.sink.endpoint.keyName=${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId}
camel.beans.aggregate=#class:org.apache.camel.kafkaconnector.aggregator.StringAggregator
-camel.beans.aggregation.size=10
-camel.beans.aggregation.timeout=5000
+camel.aggregation.size=10
+camel.aggregation.timeout=5000
diff --git a/aws2-s3/aws2-s3-sink-with-aggregation/config/openshift/aws2-s3-sink-with-aggregation.yaml b/aws2-s3/aws2-s3-sink-with-aggregation/config/openshift/aws2-s3-sink-with-aggregation.yaml
index 2b1aa0e..d059233 100644
--- a/aws2-s3/aws2-s3-sink-with-aggregation/config/openshift/aws2-s3-sink-with-aggregation.yaml
+++ b/aws2-s3/aws2-s3-sink-with-aggregation/config/openshift/aws2-s3-sink-with-aggregation.yaml
@@ -15,8 +15,8 @@ spec:
camel.sink.path.bucketNameOrArn: camel-kafka-connector
camel.sink.endpoint.keyName: ${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId}
camel.beans.aggregate: #class:org.apache.camel.kafkaconnector.aggregator.StringAggregator
- camel.beans.aggregation.size: 10
- camel.beans.aggregation.timeout: 5000
+ camel.aggregation.size: 10
+ camel.aggregation.timeout: 5000
camel.component.aws2-s3.accessKey: ${file:/opt/kafka/external-configuration/aws-credentials/aws2-s3-cred.properties:accessKey}
camel.component.aws2-s3.secretKey: ${file:/opt/kafka/external-configuration/aws-credentials/aws2-s3-cred.properties:secretKey}
camel.component.aws2-s3.region: ${file:/opt/kafka/external-configuration/aws-credentials/aws2-s3-cred.properties:region}