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 11:02:04 UTC
[camel-kafka-connector] branch conv-aggr-transform-alignment
updated (4bc8f84 -> b036c63)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch conv-aggr-transform-alignment
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
omit 4bc8f84 Add converters, transforms and aggregationStrategies to catalog - Fixed catalog test
omit 5860aa1 Add converters, transforms and aggregationStrategies to catalog - regen catalog
omit 07c1230 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-sqs
omit 45935ff Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-s3
omit d675ab0 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws-s3
omit ba561d3 Add converters, transforms and aggregationStrategies to catalog, fixed CS
omit 5b309a1 Add converters, transforms and aggregationStrategies to catalog, regen
omit 668754e Add converters, transforms and aggregationStrategies to catalog
add 6b7b0ef Avoid usage of static for Camel Kafka Connector catalog
add b81123d Add converters, transforms and aggregationStrategies to catalog
add e3ab7ff Add converters, transforms and aggregationStrategies to catalog, regen
add 4caea4b Add converters, transforms and aggregationStrategies to catalog, fixed CS
new a592afe Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws-s3
new e72924e Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-s3
new 7af8931 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws2-sqs
new 99c98ab Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - regen catalog
new b036c63 Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - Fixed catalog test
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (4bc8f84)
\
N -- N -- N refs/heads/conv-aggr-transform-alignment (b036c63)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
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:
.../camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
[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 conv-aggr-transform-alignment
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 7af8931f617084e0dc0c33038c786026f2fb4922
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] 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 conv-aggr-transform-alignment
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit a592afea3bc88f873a5743acfba3a11c2e3c03c2
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] 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 conv-aggr-transform-alignment
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit b036c630b8182f61d53de2350ea5196ea0edfbae
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 conv-aggr-transform-alignment
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 99c98aba65e6d5eeb79db9563ae7623bac01092c
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.
[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 conv-aggr-transform-alignment
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit e72924ea4aad043a227149dcac7709a3a3e5557c
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 ");