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 <[email protected]> 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]
