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:29 UTC
[camel-kafka-connector-examples] branch aws2-s3-sink-aggr created
(now a7fe033)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch aws2-s3-sink-aggr
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector-examples.git.
at a7fe033 Zip Aggregation on AWS2-S3 example: Fixed naming of camel.beans.aggregation options to camel.aggregation for config files
This branch includes the following new commits:
new 1794d16 Aggregation on AWS2-S3 example: Fixed naming of camel.beans.aggregation options to camel.aggregation
new 0ad34bc Aggregation on AWS2-S3 example: Fixed naming of camel.beans.aggregation options to camel.aggregation for config files
new 66e4b1f Zip Aggregation on AWS2-S3 example: Fixed naming of camel.beans.aggregation options to camel.aggregation
new a7fe033 Zip Aggregation on AWS2-S3 example: Fixed naming of camel.beans.aggregation options to camel.aggregation for config files
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel-kafka-connector-examples] 04/04: Zip Aggregation on AWS2-S3
example: Fixed naming of camel.beans.aggregation options to
camel.aggregation for config files
Posted by ac...@apache.org.
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 a7fe0331fd11d271caca60261a012a589a2cb96d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jan 11 13:39:01 2021 +0100
Zip 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-zip-aggregation.yaml | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/aws2-s3/aws2-s3-sink-with-zip-aggregation/config/CamelAWS2S3SinkConnector.properties b/aws2-s3/aws2-s3-sink-with-zip-aggregation/config/CamelAWS2S3SinkConnector.properties
index 5490c06..cbb54fc 100644
--- a/aws2-s3/aws2-s3-sink-with-zip-aggregation/config/CamelAWS2S3SinkConnector.properties
+++ b/aws2-s3/aws2-s3-sink-with-zip-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}.zip
camel.beans.aggregate=#class:org.apache.camel.processor.aggregate.zipfile.ZipAggregationStrategy
-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-zip-aggregation/config/openshift/aws2-s3-sink-with-zip-aggregation.yaml b/aws2-s3/aws2-s3-sink-with-zip-aggregation/config/openshift/aws2-s3-sink-with-zip-aggregation.yaml
index 13b5bd5..3209f45 100644
--- a/aws2-s3/aws2-s3-sink-with-zip-aggregation/config/openshift/aws2-s3-sink-with-zip-aggregation.yaml
+++ b/aws2-s3/aws2-s3-sink-with-zip-aggregation/config/openshift/aws2-s3-sink-with-zip-aggregation.yaml
@@ -15,8 +15,8 @@ spec:
camel.sink.path.bucketNameOrArn: camel-kafka-connector
camel.sink.endpoint.keyName: ${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId}.zip
camel.beans.aggregate: #class:org.apache.camel.processor.aggregate.zipfile.ZipAggregationStrategy
- 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}
[camel-kafka-connector-examples] 01/04: Aggregation on AWS2-S3
example: Fixed naming of camel.beans.aggregation options to
camel.aggregation
Posted by ac...@apache.org.
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 1794d165d0d1b0b87e2e3c9f589b71e4b896d723
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jan 11 13:32:39 2021 +0100
Aggregation on AWS2-S3 example: Fixed naming of camel.beans.aggregation options to camel.aggregation
---
aws2-s3/aws2-s3-sink-with-aggregation/README.adoc | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/aws2-s3/aws2-s3-sink-with-aggregation/README.adoc b/aws2-s3/aws2-s3-sink-with-aggregation/README.adoc
index af56e06..12d897f 100644
--- a/aws2-s3/aws2-s3-sink-with-aggregation/README.adoc
+++ b/aws2-s3/aws2-s3-sink-with-aggregation/README.adoc
@@ -53,8 +53,8 @@ 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
```
and add the correct credentials for AWS.
@@ -235,8 +235,8 @@ oc exec -i `oc get pods --field-selector status.phase=Running -l strimzi.io/name
"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": "xxx",
"camel.component.aws2-s3.secretKey": "xxx",
"camel.component.aws2-s3.region": "xxx"
@@ -267,8 +267,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: xxxx
camel.component.aws2-s3.secretKey: yyyy
camel.component.aws2-s3.region: region
[camel-kafka-connector-examples] 03/04: Zip Aggregation on AWS2-S3
example: Fixed naming of camel.beans.aggregation options to
camel.aggregation
Posted by ac...@apache.org.
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 66e4b1f0fcd1dbcf210b6474b6df4001d511471b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jan 11 13:38:13 2021 +0100
Zip Aggregation on AWS2-S3 example: Fixed naming of camel.beans.aggregation options to camel.aggregation
---
aws2-s3/aws2-s3-sink-with-zip-aggregation/README.adoc | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/aws2-s3/aws2-s3-sink-with-zip-aggregation/README.adoc b/aws2-s3/aws2-s3-sink-with-zip-aggregation/README.adoc
index d7ce50b..0ecb70b 100644
--- a/aws2-s3/aws2-s3-sink-with-zip-aggregation/README.adoc
+++ b/aws2-s3/aws2-s3-sink-with-zip-aggregation/README.adoc
@@ -148,8 +148,8 @@ camel.component.aws2-s3.region=eu-west-1
camel.sink.endpoint.keyName=${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId}.zip
camel.beans.aggregate=#class:org.apache.camel.processor.aggregate.zipfile.ZipAggregationStrategy
-camel.beans.aggregation.size=10
-camel.beans.aggregation.timeout=5000
+camel.aggregation.size=10
+camel.aggregation.timeout=5000
```
and add the correct credentials for AWS.
@@ -417,8 +417,8 @@ oc exec -i `oc get pods --field-selector status.phase=Running -l strimzi.io/name
"camel.sink.path.bucketNameOrArn": "camel-kafka-connector",
"camel.sink.endpoint.keyName": "${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId}.zip",
"camel.beans.aggregate": "#class:org.apache.camel.processor.aggregate.zipfile.ZipAggregationStrategy",
- "camel.beans.aggregation.size": "10",
- "camel.beans.aggregation.timeout": "5000",
+ "camel.aggregation.size": "10",
+ "camel.aggregation.timeout": "5000",
"camel.component.aws2-s3.accessKey": "xxx",
"camel.component.aws2-s3.secretKey": "xxx",
"camel.component.aws2-s3.region": "xxx"
@@ -449,8 +449,8 @@ spec:
camel.sink.path.bucketNameOrArn: camel-kafka-connector
camel.sink.endpoint.keyName: ${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId}.zip
camel.beans.aggregate: #class:org.apache.camel.processor.aggregate.zipfile.ZipAggregationStrategy
- camel.beans.aggregation.size: 10
- camel.beans.aggregation.timeout: 5000
+ camel.aggregation.size: 10
+ camel.aggregation.timeout: 5000
camel.component.aws2-s3.accessKey: xxxx
camel.component.aws2-s3.secretKey: yyyy
camel.component.aws2-s3.region: region
[camel-kafka-connector-examples] 02/04: Aggregation on AWS2-S3
example: Fixed naming of camel.beans.aggregation options to
camel.aggregation for config files
Posted by ac...@apache.org.
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}