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/07/22 06:47:53 UTC
[camel-kafka-connector] 03/05: Regen and fix the SMT for AWS2-s3
from json to record
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 5fb0350578b3c0e953454d035052e18e6f0c2b2a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Jul 22 08:31:10 2021 +0200
Regen and fix the SMT for AWS2-s3 from json to record
---
.../src/generated/resources/connectors/camel-aws2-s3-sink.json | 4 +++-
.../generated/resources/connectors/camel-aws2-s3-source.json | 4 +++-
connectors/camel-aws2-s3-kafka-connector/pom.xml | 10 +++++-----
.../src/generated/resources/camel-aws2-s3-sink.json | 4 +++-
.../src/generated/resources/camel-aws2-s3-source.json | 4 +++-
.../src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc | 6 +++++-
.../src/main/docs/camel-aws2-s3-kafka-source-connector.adoc | 6 +++++-
.../aws2s3/transformers/JSONToRecordTransforms.java | 2 ++
docs/modules/ROOT/nav.adoc | 5 +++++
.../pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc | 6 +++++-
.../pages/connectors/camel-aws2-s3-kafka-source-connector.adoc | 6 +++++-
docs/modules/ROOT/pages/reference/index.adoc | 4 +++-
12 files changed, 47 insertions(+), 14 deletions(-)
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 22c27d8..ffd4262 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
@@ -519,7 +519,9 @@
"org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
],
"transforms": [
- "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms"
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms",
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.JSONToRecordTransforms",
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms"
],
"aggregationStrategies": [
"org.apache.camel.kafkaconnector.aws2s3.aggregation.NewlineAggregationStrategy"
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 10b67dd..034319c 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
@@ -605,7 +605,9 @@
"org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
],
"transforms": [
- "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms"
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms",
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.JSONToRecordTransforms",
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms"
],
"aggregationStrategies": [
"org.apache.camel.kafkaconnector.aws2s3.aggregation.NewlineAggregationStrategy"
diff --git a/connectors/camel-aws2-s3-kafka-connector/pom.xml b/connectors/camel-aws2-s3-kafka-connector/pom.xml
index d7318a8..3090b8b 100644
--- a/connectors/camel-aws2-s3-kafka-connector/pom.xml
+++ b/connectors/camel-aws2-s3-kafka-connector/pom.xml
@@ -44,6 +44,11 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws2-s3</artifactId>
</dependency>
+ <dependency>
+ <groupId>com.google.code.gson</groupId>
+ <artifactId>gson</artifactId>
+ <version>2.8.7</version>
+ </dependency>
<!--START OF GENERATED CODE-->
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
@@ -54,11 +59,6 @@
<artifactId>camel-jackson</artifactId>
</dependency>
<!--END OF GENERATED CODE-->
- <dependency>
- <groupId>com.google.code.gson</groupId>
- <artifactId>gson</artifactId>
- <version>2.8.7</version>
- </dependency>
</dependencies>
<build>
<plugins>
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 22c27d8..ffd4262 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
@@ -519,7 +519,9 @@
"org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
],
"transforms": [
- "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms"
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms",
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.JSONToRecordTransforms",
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms"
],
"aggregationStrategies": [
"org.apache.camel.kafkaconnector.aws2s3.aggregation.NewlineAggregationStrategy"
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 10b67dd..034319c 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
@@ -605,7 +605,9 @@
"org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
],
"transforms": [
- "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms"
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms",
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.JSONToRecordTransforms",
+ "org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms"
],
"aggregationStrategies": [
"org.apache.camel.kafkaconnector.aws2s3.aggregation.NewlineAggregationStrategy"
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 badf7a8..6840a85 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
@@ -119,7 +119,7 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws2-s3 sink connector supports 3 transforms out of the box, which are listed below.
@@ -128,6 +128,10 @@ The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are
org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms
+org.apache.camel.kafkaconnector.aws2s3.transformers.JSONToRecordTransforms
+
+org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms
+
----
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 f1fd218..9e58a4a 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
@@ -135,7 +135,7 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 source connector supports 1 transforms out of the box, which are listed below.
+The camel-aws2-s3 source connector supports 3 transforms out of the box, which are listed below.
@@ -144,6 +144,10 @@ The camel-aws2-s3 source connector supports 1 transforms out of the box, which a
org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms
+org.apache.camel.kafkaconnector.aws2s3.transformers.JSONToRecordTransforms
+
+org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms
+
----
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/JSONToRecordTransforms.java b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/JSONToRecordTransforms.java
index 2d28425..8ef4c53 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/JSONToRecordTransforms.java
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/JSONToRecordTransforms.java
@@ -19,6 +19,8 @@ package org.apache.camel.kafkaconnector.aws2s3.transformers;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import java.util.Map;
+
+import org.apache.camel.kafkaconnector.aws2s3.models.StorageRecord;
import org.apache.kafka.common.config.ConfigDef;
import org.apache.kafka.connect.connector.ConnectRecord;
import org.apache.kafka.connect.header.ConnectHeaders;
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index dce5c21..46c36f7 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -37,6 +37,9 @@
*** camel-amqp-kafka-connector
**** xref:reference/connectors/camel-amqp-kafka-source-connector.adoc[Source Docs]
**** xref:reference/connectors/camel-amqp-kafka-sink-connector.adoc[Sink Docs]
+*** camel-apns-kafka-connector
+**** xref:reference/connectors/camel-apns-kafka-source-connector.adoc[Source Docs]
+**** xref:reference/connectors/camel-apns-kafka-sink-connector.adoc[Sink Docs]
*** camel-arangodb-kafka-connector
**** xref:reference/connectors/camel-arangodb-kafka-sink-connector.adoc[Sink Docs]
*** camel-as2-kafka-connector
@@ -198,6 +201,8 @@
**** xref:reference/connectors/camel-cql-kafka-sink-connector.adoc[Sink Docs]
*** camel-cron-kafka-connector
**** xref:reference/connectors/camel-cron-kafka-source-connector.adoc[Source Docs]
+*** camel-crypto-cms-kafka-connector
+**** xref:reference/connectors/camel-crypto-cms-kafka-sink-connector.adoc[Sink Docs]
*** camel-crypto-kafka-connector
**** xref:reference/connectors/camel-crypto-kafka-sink-connector.adoc[Sink Docs]
*** camel-cxf-kafka-connector
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 badf7a8..6840a85 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
@@ -119,7 +119,7 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws2-s3 sink connector supports 3 transforms out of the box, which are listed below.
@@ -128,6 +128,10 @@ The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are
org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms
+org.apache.camel.kafkaconnector.aws2s3.transformers.JSONToRecordTransforms
+
+org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms
+
----
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 f1fd218..9e58a4a 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
@@ -135,7 +135,7 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 source connector supports 1 transforms out of the box, which are listed below.
+The camel-aws2-s3 source connector supports 3 transforms out of the box, which are listed below.
@@ -144,6 +144,10 @@ The camel-aws2-s3 source connector supports 1 transforms out of the box, which a
org.apache.camel.kafkaconnector.aws2s3.transformers.S3ObjectTransforms
+org.apache.camel.kafkaconnector.aws2s3.transformers.JSONToRecordTransforms
+
+org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms
+
----
diff --git a/docs/modules/ROOT/pages/reference/index.adoc b/docs/modules/ROOT/pages/reference/index.adoc
index 04e976a..1eab44f 100644
--- a/docs/modules/ROOT/pages/reference/index.adoc
+++ b/docs/modules/ROOT/pages/reference/index.adoc
@@ -2,7 +2,7 @@
= Supported connectors and documentation
// kafka-connectors list: START
-Number of Camel Kafka connectors: 340
+Number of Camel Kafka connectors: 342
[width="100%",cols="4,1,1,1,1,1",options="header"]
|===
@@ -12,6 +12,7 @@ Number of Camel Kafka connectors: 340
| *camel-ahc-ws-kafka-connector* | true | true | xref:reference/connectors/camel-ahc-ws-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-ahc-ws-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-ahc-ws-kafka-connector/0.10.0/camel-ahc-ws-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-ahc-wss-kafka-connector* | true | true | xref:reference/connectors/camel-ahc-wss-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-ahc-wss-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-ahc-wss-kafka-connector/0.10.0/camel-ahc-wss-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-amqp-kafka-connector* | true | true | xref:reference/connectors/camel-amqp-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-amqp-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-amqp-kafka-connector/0.10.0/camel-amqp-kafka-connector-0.10.0-package.tar.gz[Download]
+| *camel-apns-kafka-connector* | true | true | xref:reference/connectors/camel-apns-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-apns-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-apns-kafka-connector/0.10.0/camel-apns-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-arangodb-kafka-connector* | true | false | xref:reference/connectors/camel-arangodb-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-arangodb-kafka-connector/0.10.0/camel-arangodb-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-as2-kafka-connector* | true | true | xref:reference/connectors/camel-as2-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-as2-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-as2-kafka-connector/0.10.0/camel-as2-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-asterisk-kafka-connector* | true | true | xref:reference/connectors/camel-asterisk-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-asterisk-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-asterisk-kafka-connector/0.10.0/camel-asterisk-kafka-connector-0.10.0-package.tar.gz[Download]
@@ -76,6 +77,7 @@ Number of Camel Kafka connectors: 340
| *camel-couchdb-kafka-connector* | true | true | xref:reference/connectors/camel-couchdb-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-couchdb-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-couchdb-kafka-connector/0.10.0/camel-couchdb-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-cql-kafka-connector* | true | true | xref:reference/connectors/camel-cql-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-cql-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-cql-kafka-connector/0.10.0/camel-cql-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-cron-kafka-connector* | false | true | | xref:reference/connectors/camel-cron-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-cron-kafka-connector/0.10.0/camel-cron-kafka-connector-0.10.0-package.tar.gz[Download]
+| *camel-crypto-cms-kafka-connector* | true | false | xref:reference/connectors/camel-crypto-cms-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-crypto-cms-kafka-connector/0.10.0/camel-crypto-cms-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-crypto-kafka-connector* | true | false | xref:reference/connectors/camel-crypto-kafka-sink-connector.adoc[Sink Docs] | | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-crypto-kafka-connector/0.10.0/camel-crypto-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-cxf-kafka-connector* | true | true | xref:reference/connectors/camel-cxf-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-cxf-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-cxf-kafka-connector/0.10.0/camel-cxf-kafka-connector-0.10.0-package.tar.gz[Download]
| *camel-cxfrs-kafka-connector* | true | true | xref:reference/connectors/camel-cxfrs-kafka-sink-connector.adoc[Sink Docs] | xref:reference/connectors/camel-cxfrs-kafka-source-connector.adoc[Source Docs] | https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector/camel-cxfrs-kafka-connector/0.10.0/camel-cxfrs-kafka-connector-0.10.0-package.tar.gz[Download]