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 2020/10/14 12:32:40 UTC
[camel-kafka-connector] branch master updated (03d2872 -> 061e066)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 03d2872 Adjust the text to replace the WIP with a better description of the project maturity
new 26ec045 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws-s3
new 9189c24 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-s3
new cad62c4 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-sqs
new 224c808 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - regen catalog
new 061e066 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - Fixed catalog test
The 5 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.
Summary of changes:
.../src/generated/resources/connectors/camel-aws-s3-sink.json | 3 +++
.../src/generated/resources/connectors/camel-aws-s3-source.json | 3 +++
.../src/generated/resources/connectors/camel-aws2-s3-sink.json | 3 +++
.../src/generated/resources/connectors/camel-aws2-s3-source.json | 3 +++
.../src/generated/resources/connectors/camel-aws2-sqs-sink.json | 5 ++++-
.../generated/resources/connectors/camel-aws2-sqs-source.json | 5 ++++-
.../kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java | 2 +-
.../src/generated/resources/camel-aws-s3-sink.json | 3 +++
.../src/generated/resources/camel-aws-s3-source.json | 3 +++
.../src/main/docs/camel-aws-s3-kafka-sink-connector.adoc | 9 ++++++++-
.../src/main/docs/camel-aws-s3-kafka-source-connector.adoc | 9 ++++++++-
.../{S3ObjectTransformer.java => S3ObjectTransforms.java} | 2 +-
.../src/generated/resources/camel-aws2-s3-sink.json | 3 +++
.../src/generated/resources/camel-aws2-s3-source.json | 3 +++
.../src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc | 9 ++++++++-
.../src/main/docs/camel-aws2-s3-kafka-source-connector.adoc | 9 ++++++++-
.../{S3ObjectTransformers.java => S3ObjectTransforms.java} | 2 +-
.../src/generated/resources/camel-aws2-sqs-sink.json | 5 ++++-
.../src/generated/resources/camel-aws2-sqs-source.json | 5 ++++-
.../src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc | 9 ++++++++-
.../src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc | 9 ++++++++-
...SQSKeySetterTransformers.java => SQSKeySetterTransforms.java} | 2 +-
.../ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws-s3-kafka-source-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws2-s3-kafka-source-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc | 9 ++++++++-
28 files changed, 140 insertions(+), 20 deletions(-)
rename connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/{S3ObjectTransformer.java => S3ObjectTransforms.java} (95%)
rename connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/{S3ObjectTransformers.java => S3ObjectTransforms.java} (95%)
rename connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/{SQSKeySetterTransformers.java => SQSKeySetterTransforms.java} (95%)
[camel-kafka-connector] 02/05: Rename all transformers, converters,
aggregationStrategies to reflect the maning convention we have -
aws2-s3
Posted by ac...@apache.org.
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-kafka-connector.git
commit 9189c2421f9bf2a71feeec9b731e5282764efd35
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 11:42:54 2020 +0200
Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-s3
---
.../transformers/{S3ObjectTransformers.java => S3ObjectTransforms.java} | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransformers.java b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransforms.java
similarity index 95%
rename from connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransformers.java
rename to connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransforms.java
index fa6e80b..2e5a837 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransformers.java
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransforms.java
@@ -25,7 +25,7 @@ import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.transforms.Transformation;
import software.amazon.awssdk.core.ResponseInputStream;
-public class S3ObjectTransformers<R extends ConnectRecord<R>> implements Transformation<R> {
+public class S3ObjectTransforms<R extends ConnectRecord<R>> implements Transformation<R> {
public static final ConfigDef CONFIG_DEF = new ConfigDef().define("test", ConfigDef.Type.STRING, "test", ConfigDef.Importance.MEDIUM,
"Transform the content of a bucket into a string ");
[camel-kafka-connector] 01/05: Rename all transformers, converters,
aggregationStrategies to reflect the maning convention we have -
aws-s3
Posted by ac...@apache.org.
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-kafka-connector.git
commit 26ec04505aa3486e00ca8b57f98190ec86c3ff67
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 11:41:25 2020 +0200
Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws-s3
---
.../transformers/{S3ObjectTransformer.java => S3ObjectTransforms.java} | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java b/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransforms.java
similarity index 95%
rename from connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java
rename to connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransforms.java
index 3dd9339..918770e 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java
+++ b/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransforms.java
@@ -25,7 +25,7 @@ import org.apache.kafka.connect.connector.ConnectRecord;
import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.transforms.Transformation;
-public class S3ObjectTransformer<R extends ConnectRecord<R>> implements Transformation<R> {
+public class S3ObjectTransforms<R extends ConnectRecord<R>> implements Transformation<R> {
public static final ConfigDef CONFIG_DEF = new ConfigDef()
.define("test", ConfigDef.Type.STRING, "test", ConfigDef.Importance.MEDIUM, "Transform the content of a bucket into a string ");
[camel-kafka-connector] 03/05: Rename all transformers, converters,
aggregationStrategies to reflect the maning convention we have -
aws2-sqs
Posted by ac...@apache.org.
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-kafka-connector.git
commit cad62c4d054ee6b294f26ef4192d167d886db72d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 11:45:42 2020 +0200
Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-sqs
---
.../{SQSKeySetterTransformers.java => SQSKeySetterTransforms.java} | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java
similarity index 95%
rename from connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java
rename to connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java
index 7da0da4..1a14c46 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransforms.java
@@ -24,7 +24,7 @@ import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.header.Headers;
import org.apache.kafka.connect.transforms.Transformation;
-public class SQSKeySetterTransformers<R extends ConnectRecord<R>> implements Transformation<R> {
+public class SQSKeySetterTransforms<R extends ConnectRecord<R>> implements Transformation<R> {
public static final ConfigDef CONFIG_DEF = new ConfigDef()
.define("test", ConfigDef.Type.STRING, "test", ConfigDef.Importance.MEDIUM, "Fetch the Camel.CamelAwsSqsMessageId header and set it as the key for the kafka record");
[camel-kafka-connector] 05/05: Rename all transformers, converters,
aggregationStrategies to reflect the maning convention we have -
Fixed catalog test
Posted by ac...@apache.org.
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-kafka-connector.git
commit 061e0660203eba0aed1f6f8b01d2f29f7c57672b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 12:38:00 2020 +0200
Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - Fixed catalog test
---
.../camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java b/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
index 81a67eb..2c146c4 100644
--- a/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
+++ b/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
@@ -58,7 +58,7 @@ class CamelKafkaConnectorCatalogTest {
assertEquals("camel.sink.endpoint.amazonS3Client", model.getOptions().get(1).getName());
assertEquals("camel.sink.endpoint.autoCreateBucket", model.getOptions().get(2).getName());
assertEquals(model.getConverters().size(), 1);
- assertNull(model.getTransforms());
+ assertEquals(model.getTransforms().size(), 1);
assertNull(model.getAggregationStrategies());
}
[camel-kafka-connector] 04/05: Rename all transformers, converters,
aggregationStrategies to reflect the maning convention we have -
regen catalog
Posted by ac...@apache.org.
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-kafka-connector.git
commit 224c8081f180e0239567e8a47eae4f9963dd312e
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 12:34:32 2020 +0200
Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - regen catalog
---
.../src/generated/resources/connectors/camel-aws-s3-sink.json | 3 +++
.../src/generated/resources/connectors/camel-aws-s3-source.json | 3 +++
.../src/generated/resources/connectors/camel-aws2-s3-sink.json | 3 +++
.../src/generated/resources/connectors/camel-aws2-s3-source.json | 3 +++
.../src/generated/resources/connectors/camel-aws2-sqs-sink.json | 5 ++++-
.../generated/resources/connectors/camel-aws2-sqs-source.json | 5 ++++-
.../src/generated/resources/camel-aws-s3-sink.json | 3 +++
.../src/generated/resources/camel-aws-s3-source.json | 3 +++
.../src/main/docs/camel-aws-s3-kafka-sink-connector.adoc | 9 ++++++++-
.../src/main/docs/camel-aws-s3-kafka-source-connector.adoc | 9 ++++++++-
.../src/generated/resources/camel-aws2-s3-sink.json | 3 +++
.../src/generated/resources/camel-aws2-s3-source.json | 3 +++
.../src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc | 9 ++++++++-
.../src/main/docs/camel-aws2-s3-kafka-source-connector.adoc | 9 ++++++++-
.../src/generated/resources/camel-aws2-sqs-sink.json | 5 ++++-
.../src/generated/resources/camel-aws2-sqs-source.json | 5 ++++-
.../src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc | 9 ++++++++-
.../src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc | 9 ++++++++-
.../ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws-s3-kafka-source-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws2-s3-kafka-source-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc | 9 ++++++++-
.../pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc | 9 ++++++++-
24 files changed, 136 insertions(+), 16 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
index 0dbb518..6ea8031 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
@@ -371,5 +371,8 @@
},
"converters": [
"org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter"
+ ],
+ "transforms": [
+ "org.apache.camel.kafkaconnector.awss3.transformers.S3ObjectTransforms"
]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
index d0ef24c..e4008a9 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
@@ -451,5 +451,8 @@
},
"converters": [
"org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter"
+ ],
+ "transforms": [
+ "org.apache.camel.kafkaconnector.awss3.transformers.S3ObjectTransforms"
]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
index 0f8809d..ffc0deb 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
@@ -345,5 +345,8 @@
},
"converters": [
"org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
+ ],
+ "transforms": [
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms"
]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
index 8f8b6e7..655e040 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
@@ -477,5 +477,8 @@
},
"converters": [
"org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
+ ],
+ "transforms": [
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms"
]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-sink.json
index a154bb2..bb2d2e8 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-sink.json
@@ -309,5 +309,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "transforms": [
+ "org.apache.camel.kafkaconnector.aws2sqs.transformers.SQSKeySetterTransforms"
+ ]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-source.json
index c5a7d1c..9f25a86 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-sqs-source.json
@@ -502,5 +502,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "transforms": [
+ "org.apache.camel.kafkaconnector.aws2sqs.transformers.SQSKeySetterTransforms"
+ ]
}
\ No newline at end of file
diff --git a/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json b/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json
index 0dbb518..6ea8031 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json
+++ b/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json
@@ -371,5 +371,8 @@
},
"converters": [
"org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter"
+ ],
+ "transforms": [
+ "org.apache.camel.kafkaconnector.awss3.transformers.S3ObjectTransforms"
]
}
\ No newline at end of file
diff --git a/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json b/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json
index d0ef24c..e4008a9 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json
+++ b/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json
@@ -451,5 +451,8 @@
},
"converters": [
"org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter"
+ ],
+ "transforms": [
+ "org.apache.camel.kafkaconnector.awss3.transformers.S3ObjectTransforms"
]
}
\ No newline at end of file
diff --git a/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc b/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc
index 104e65a..076a28b 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc
+++ b/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc
@@ -111,10 +111,17 @@ org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter
-The camel-aws-s3 sink connector has no transforms out of the box.
+The camel-aws-s3 sink connector supports 1 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.awss3.transformers.S3ObjectTransforms
+
+----
+
The camel-aws-s3 sink connector has no aggregation strategies out of the box.
diff --git a/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc b/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc
index a56b6b7..14757c2 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc
+++ b/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc
@@ -125,10 +125,17 @@ org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter
-The camel-aws-s3 sink connector has no transforms out of the box.
+The camel-aws-s3 sink connector supports 1 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.awss3.transformers.S3ObjectTransforms
+
+----
+
The camel-aws-s3 sink connector has no aggregation strategies out of the box.
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
index 0f8809d..ffc0deb 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
+++ b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
@@ -345,5 +345,8 @@
},
"converters": [
"org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
+ ],
+ "transforms": [
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms"
]
}
\ No newline at end of file
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
index 8f8b6e7..655e040 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
+++ b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
@@ -477,5 +477,8 @@
},
"converters": [
"org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
+ ],
+ "transforms": [
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms"
]
}
\ No newline at end of file
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
index 3fc5887..841db0a 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
@@ -107,10 +107,17 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector has no transforms out of the box.
+The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms
+
+----
+
The camel-aws2-s3 sink connector has no aggregation strategies out of the box.
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
index d02e099..53a0afd 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
@@ -131,10 +131,17 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector has no transforms out of the box.
+The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms
+
+----
+
The camel-aws2-s3 sink connector has no aggregation strategies out of the box.
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
index a154bb2..bb2d2e8 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
@@ -309,5 +309,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "transforms": [
+ "org.apache.camel.kafkaconnector.aws2sqs.transformers.SQSKeySetterTransforms"
+ ]
}
\ No newline at end of file
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
index c5a7d1c..9f25a86 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
@@ -502,5 +502,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "transforms": [
+ "org.apache.camel.kafkaconnector.aws2sqs.transformers.SQSKeySetterTransforms"
+ ]
}
\ No newline at end of file
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
index 45d0798..b9e68c6 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
@@ -95,10 +95,17 @@ The camel-aws2-sqs sink connector has no converters out of the box.
-The camel-aws2-sqs sink connector has no transforms out of the box.
+The camel-aws2-sqs sink connector supports 0 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.aws2sqs.transformers.SQSKeySetterTransforms
+
+----
+
The camel-aws2-sqs sink connector has no aggregation strategies out of the box.
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
index a30575f..99919eb 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
@@ -130,10 +130,17 @@ The camel-aws2-sqs sink connector has no converters out of the box.
-The camel-aws2-sqs sink connector has no transforms out of the box.
+The camel-aws2-sqs sink connector supports 0 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.aws2sqs.transformers.SQSKeySetterTransforms
+
+----
+
The camel-aws2-sqs sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc
index 104e65a..076a28b 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc
@@ -111,10 +111,17 @@ org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter
-The camel-aws-s3 sink connector has no transforms out of the box.
+The camel-aws-s3 sink connector supports 1 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.awss3.transformers.S3ObjectTransforms
+
+----
+
The camel-aws-s3 sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc
index a56b6b7..14757c2 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc
@@ -125,10 +125,17 @@ org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter
-The camel-aws-s3 sink connector has no transforms out of the box.
+The camel-aws-s3 sink connector supports 1 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.awss3.transformers.S3ObjectTransforms
+
+----
+
The camel-aws-s3 sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
index 3fc5887..841db0a 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
@@ -107,10 +107,17 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector has no transforms out of the box.
+The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms
+
+----
+
The camel-aws2-s3 sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
index d02e099..53a0afd 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
@@ -131,10 +131,17 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector has no transforms out of the box.
+The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms
+
+----
+
The camel-aws2-s3 sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
index 45d0798..b9e68c6 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
@@ -95,10 +95,17 @@ The camel-aws2-sqs sink connector has no converters out of the box.
-The camel-aws2-sqs sink connector has no transforms out of the box.
+The camel-aws2-sqs sink connector supports 0 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.aws2sqs.transformers.SQSKeySetterTransforms
+
+----
+
The camel-aws2-sqs sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
index a30575f..99919eb 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
@@ -130,10 +130,17 @@ The camel-aws2-sqs sink connector has no converters out of the box.
-The camel-aws2-sqs sink connector has no transforms out of the box.
+The camel-aws2-sqs sink connector supports 0 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.aws2sqs.transformers.SQSKeySetterTransforms
+
+----
+
The camel-aws2-sqs sink connector has no aggregation strategies out of the box.