[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated (be185bc -> 9e27ade)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. discard be185bc [maven-release-plugin] prepare for next development iteration new 01b3981 [after release perform chore]: regen catalog descriptors with new version. new 9e27ade [maven-release-plugin] prepare for next development iteration 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 (be185bc) \ N -- N -- N refs/heads/camel-kafka-connector-0.7.x (9e27ade) 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 2 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-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json | 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json| 2 +- .../src/generated/resources/connectors/camel-as2-source.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-source.json| 2 +- .../resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../generated/resources/connectors/camel-atomix-multimap-sink.json| 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink.json| 2 +- .../generated/resources/connectors/camel-aws-ddbstream-source.json| 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-ecs-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-eks-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-iam-sink.json| 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-source.json | 2 +- .../src/gene
svn commit: r45060 - in /release/camel/camel-kafka-connector/0.7.0: ./ camel-kafka-connector-0.7.0-src.zip camel-kafka-connector-0.7.0-src.zip.asc camel-kafka-connector-0.7.0-src.zip.sha512
Author: valdar Date: Wed Dec 23 22:04:46 2020 New Revision: 45060 Log: Camel Kafka Connector 0.7.0 import. Added: release/camel/camel-kafka-connector/0.7.0/ release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip (with props) release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip.asc (with props) release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip.sha512 Added: release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip.sha512 == --- release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/0.7.0/camel-kafka-connector-0.7.0-src.zip.sha512 Wed Dec 23 22:04:46 2020 @@ -0,0 +1 @@ +925a981e344bdb557a38ae1c6c94238dae2542c4fcdb6ee4179f7b38b6bbd35e0c1e1939a5346140894694297709e256680147ecc55a6dc4598b85815703ee6f camel-kafka-connector-0.7.0-src.zip
[camel-website] branch master updated: Edited Camel-kafka-connector-070-Whatsnew blog post (#519)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-website.git The following commit(s) were added to refs/heads/master by this push: new 0950b64 Edited Camel-kafka-connector-070-Whatsnew blog post (#519) 0950b64 is described below commit 0950b6485ad31e324381a6576f36f273a6b8f993 Author: Andrea Tarocchi AuthorDate: Thu Dec 24 01:06:57 2020 +0100 Edited Camel-kafka-connector-070-Whatsnew blog post (#519) --- content/blog/2020/12/Camel-kafka-connector-070-Whatsnew/index.md | 4 1 file changed, 4 insertions(+) diff --git a/content/blog/2020/12/Camel-kafka-connector-070-Whatsnew/index.md b/content/blog/2020/12/Camel-kafka-connector-070-Whatsnew/index.md index 57a89f1..3cce53f 100644 --- a/content/blog/2020/12/Camel-kafka-connector-070-Whatsnew/index.md +++ b/content/blog/2020/12/Camel-kafka-connector-070-Whatsnew/index.md @@ -46,6 +46,10 @@ There are situation in which you'll be using a Camel-Kafka-Connector source conn In the [camel-kafka-connector-examples repository](https://github.com/apache/camel-kafka-connector-examples/tree/master/aws2-s3/aws2-s3-move-bucket-to-bucket) we provided a little example based on 0.7.0 SNAPSHOT version. +### Json marshal/unmarshal present by default in each connector + +We added `camel-jackson` in each connector so that is possible to use `json-jackson` marshal/unmarshal out of the box. + ### New Archetypes We added two new archetypes:
[camel-website] branch master updated: Created ckc 0.7.0 release note (#518)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-website.git The following commit(s) were added to refs/heads/master by this push: new e3b084b Created ckc 0.7.0 release note (#518) e3b084b is described below commit e3b084bbc79345f3b4377730bfaa6401b024e7d4 Author: Andrea Tarocchi AuthorDate: Thu Dec 24 01:06:40 2020 +0100 Created ckc 0.7.0 release note (#518) --- content/releases/ckc/release-0.7.0.md | 10 ++ 1 file changed, 10 insertions(+) diff --git a/content/releases/ckc/release-0.7.0.md b/content/releases/ckc/release-0.7.0.md new file mode 100644 index 000..ff5f884 --- /dev/null +++ b/content/releases/ckc/release-0.7.0.md @@ -0,0 +1,10 @@ +--- +url: "/releases/ckc-0.7.0/" +date: 2020-12-23 +type: release-note +version: "0.7.0" +title: "Camel Kafka Connector release 0.7.0" +preview: "" +changelog: "" +category: "camel-kafka-connector" +---
[camel-website] branch valdar-ckc-0.7.0 created (now e5d06ab)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-ckc-0.7.0 in repository https://gitbox.apache.org/repos/asf/camel-website.git. at e5d06ab Created ckc 0.7.0 release note No new revisions were added by this update.
[camel-website] branch valdar-blogpost created (now bea8c41)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-blogpost in repository https://gitbox.apache.org/repos/asf/camel-website.git. at bea8c41 Edited Camel-kafka-connector-070-Whatsnew blog post No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-0.7.x created (now c7a5d83)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at c7a5d83 [maven-release-plugin] prepare release camel-kafka-connector-0.7.0 This branch includes the following new commits: new c7a5d83 [maven-release-plugin] prepare release camel-kafka-connector-0.7.0 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.0 created (now e600c2b)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at e600c2b (tag) tagging c7a5d83dfedb4413e69a9b9bc1ee4b9a987b4db9 (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Mon Dec 21 02:53:41 2020 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.7.0 --- No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-0.7.x deleted (was 1bd65c1)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. was 1bd65c1 [maven-release-plugin] prepare for next development iteration This change permanently discards the following revisions: discard 1bd65c1 [maven-release-plugin] prepare for next development iteration discard 73e023f [maven-release-plugin] prepare release camel-kafka-connector-0.7.0
[camel-kafka-connector] branch camel-kafka-connector-0.7.x deleted (was f0c9979)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. was f0c9979 [maven-release-plugin] prepare for next development iteration This change permanently discards the following revisions: discard f0c9979 [maven-release-plugin] prepare for next development iteration discard c7a5d83 [maven-release-plugin] prepare release camel-kafka-connector-0.7.0
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.0 deleted (was e600c2b)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.0 was deleted! *** tag was e600c2b The revisions that were on this annotated tag are still contained in other references; therefore, this change does not discard any commits from the repository.
[camel-kafka-connector] branch camel-kafka-connector-0.7.x created (now 39db3a0)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 39db3a0 [maven-release-plugin] prepare release camel-kafka-connector-0.7.0 This branch includes the following new commits: new 39db3a0 [maven-release-plugin] prepare release camel-kafka-connector-0.7.0 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.0 created (now e2d3761)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at e2d3761 (tag) tagging 39db3a0436f21b0975005835b3c01bab6af25545 (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Mon Dec 21 14:43:32 2020 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.7.0 --- No new revisions were added by this update.
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.0 created (now 41272ce)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 41272ce (tag) tagging 73e023fe1544ae12cdc581be00decf0ea77206ca (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Mon Dec 21 12:37:44 2020 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.7.0 --- No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-0.7.x created (now 73e023f)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 73e023f [maven-release-plugin] prepare release camel-kafka-connector-0.7.0 This branch includes the following new commits: new 73e023f [maven-release-plugin] prepare release camel-kafka-connector-0.7.0 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.0 deleted (was 41272ce)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.0 was deleted! *** tag was 41272ce The revisions that were on this annotated tag are still contained in other references; therefore, this change does not discard any commits from the repository.
[camel-kafka-connector] branch camel-kafka-connector-0.7.x created (now 8b1570a)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 8b1570a [maven-release-plugin] prepare release camel-kafka-connector-0.7.0 This branch includes the following new commits: new 8b1570a [maven-release-plugin] prepare release camel-kafka-connector-0.7.0 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.0 created (now 036de8b)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 036de8b (tag) tagging 8b1570a3e5175ac373ec04e4280ee691354e974a (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Sun Dec 20 16:19:21 2020 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.7.0 --- No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-0.7.x deleted (was b85d523)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. was b85d523 [maven-release-plugin] prepare for next development iteration This change permanently discards the following revisions: discard b85d523 [maven-release-plugin] prepare for next development iteration
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.0 deleted (was 036de8b)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.0 was deleted! *** tag was 036de8b This change permanently discards the following revisions: discard 8b1570a [maven-release-plugin] prepare release camel-kafka-connector-0.7.0
[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated: Upgrade to 3.7.1 and regen
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-0.7.x by this push: new dd8f526 Upgrade to 3.7.1 and regen dd8f526 is described below commit dd8f52658a1047ec3379946d8b111aec36aa4b84 Author: Andrea Cosentino AuthorDate: Fri Jan 22 18:20:21 2021 +0100 Upgrade to 3.7.1 and regen --- .../resources/connectors/camel-activemq-sink.json | 2 +- .../resources/connectors/camel-activemq-source.json| 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json | 2 +- .../generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../resources/connectors/camel-ahc-ws-source.json | 2 +- .../generated/resources/connectors/camel-ahc-wss-sink.json | 2 +- .../resources/connectors/camel-ahc-wss-source.json | 2 +- .../generated/resources/connectors/camel-amqp-sink.json| 2 +- .../generated/resources/connectors/camel-amqp-source.json | 2 +- .../generated/resources/connectors/camel-apns-sink.json| 2 +- .../generated/resources/connectors/camel-apns-source.json | 2 +- .../resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json | 2 +- .../generated/resources/connectors/camel-as2-source.json | 2 +- .../resources/connectors/camel-asterisk-sink.json | 2 +- .../resources/connectors/camel-asterisk-source.json| 2 +- .../resources/connectors/camel-atlasmap-sink.json | 2 +- .../generated/resources/connectors/camel-atmos-sink.json | 2 +- .../generated/resources/connectors/camel-atmos-source.json | 2 +- .../connectors/camel-atmosphere-websocket-sink.json| 2 +- .../connectors/camel-atmosphere-websocket-source.json | 2 +- .../generated/resources/connectors/camel-atom-source.json | 2 +- .../resources/connectors/camel-atomix-map-sink.json| 2 +- .../resources/connectors/camel-atomix-map-source.json | 2 +- .../resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../connectors/camel-atomix-messaging-source.json | 2 +- .../resources/connectors/camel-atomix-multimap-sink.json | 2 +- .../resources/connectors/camel-atomix-queue-sink.json | 2 +- .../resources/connectors/camel-atomix-queue-source.json| 2 +- .../resources/connectors/camel-atomix-set-sink.json| 2 +- .../resources/connectors/camel-atomix-set-source.json | 2 +- .../resources/connectors/camel-atomix-value-sink.json | 2 +- .../resources/connectors/camel-atomix-value-source.json| 2 +- .../generated/resources/connectors/camel-avro-sink.json| 2 +- .../generated/resources/connectors/camel-avro-source.json | 2 +- .../generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ddb-sink.json | 2 +- .../resources/connectors/camel-aws-ddbstream-source.json | 2 +- .../generated/resources/connectors/camel-aws-ec2-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ecs-sink.json | 2 +- .../generated/resources/connectors/camel-aws-eks-sink.json | 2 +- .../generated/resources/connectors/camel-aws-iam-sink.json | 2 +- .../connectors/camel-aws-kinesis-firehose-sink.json| 2 +- .../resources/connectors/camel-aws-kinesis-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-source.json | 2 +- .../generated/resources/connectors/camel-aws-kms-sink.json | 2 +- .../resources/connectors/camel-aws-lambda-sink.json| 2 +- .../generated/resources/connectors/camel-aws-mq-sink.json | 2 +- .../generated/resources/connectors/camel-aws-msk-sink.json | 2 +- .../generated/resources/connectors/camel-aws-s3-sink.json | 2 +- .../resources/connectors/camel-aws-s3-source.json | 2 +- .../generated/resources/connectors/camel-aws-sdb-sink.json | 2 +- .../generated/resources/connectors/camel-aws-ses-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-sink.json | 2 +- .../resources/connectors/camel-aws-sqs-source.json | 2 +- .../generated/resources/connectors/camel-aws-swf-sink.json | 2 +- .../resources/connectors/camel-aws-swf-source.json | 2 +- .../resources/connectors/camel-aws-translate-sink.json | 2 +- .../resources/connectors/camel-aws2-athena-sink.json | 2 +- .../generated/resources/connectors/camel-aws2-cw-sink.json | 2 +- .../resources/connectors/camel-aws2-ddb-sink.json | 2 +- .../resources/connectors/camel-aws2-ddbstream-source.json | 2 +- .../resources/connectors/camel-aws2-ec2-sink.json | 2 +- .../resources/connectors/camel-aws2-ecs-sink.json | 2 +- .../resources/connectors/camel-aws2-eks-sink.json
[camel-kafka-connector] 01/02: Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-kafka-connector-0.7.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 17b59c51d01bb4d80f2002bb234e3faaf0b1a907
Author: Andrea Tarocchi
AuthorDate: Fri Jan 15 00:07:18 2021 +0100
Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest
---
.../transforms/SinkPojoToSchemaAndStructTransformTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java
b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java
index 5f1655a..4ac14ca 100644
---
a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java
+++
b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java
@@ -111,7 +111,8 @@ public class SinkPojoToSchemaAndStructTransformTest {
Schema.STRING_SCHEMA, "testKeyValue",
null, map);
-sinkPojoToSchemaAndStructTransform.apply(cr);
+ConnectRecord transformedCr =
sinkPojoToSchemaAndStructTransform.apply(cr);
+assertEquals(cr, transformedCr);
}
@Test()
[camel-kafka-connector] 02/02: Added SchemaAndStructToJsonTransform fix #843
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-kafka-connector-0.7.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit dc8f444b972b1a015bfed2cd6476f83137e7c8bf
Author: Andrea Tarocchi
AuthorDate: Fri Jan 15 00:05:04 2021 +0100
Added SchemaAndStructToJsonTransform fix #843
---
.../transforms/SchemaAndStructToJsonTransform.java | 77 +
.../SchemaAndStructToJsonTransformTest.java| 128 +
2 files changed, 205 insertions(+)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java
b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java
new file mode 100644
index 000..72d10db
--- /dev/null
+++
b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.kafkaconnector.transforms;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.kafka.common.config.ConfigDef;
+import org.apache.kafka.connect.connector.ConnectRecord;
+import org.apache.kafka.connect.data.Schema;
+import org.apache.kafka.connect.json.JsonConverter;
+import org.apache.kafka.connect.json.JsonConverterConfig;
+import org.apache.kafka.connect.storage.ConverterConfig;
+import org.apache.kafka.connect.storage.ConverterType;
+import org.apache.kafka.connect.transforms.Transformation;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SchemaAndStructToJsonTransform>
implements Transformation {
+private static final Logger LOG =
LoggerFactory.getLogger(SchemaAndStructToJsonTransform.class);
+
+private JsonConverter jsonConverter;
+
+@Override
+public R apply(R r) {
+LOG.debug("Incoming record: {}", r);
+
+if (r.value() != null && r.valueSchema() != null) {
+byte[] json = jsonConverter.fromConnectData(r.topic(),
r.valueSchema(), r.value());
+
+if (json == null) {
+LOG.warn("No record was converted as part of this
transformation, resulting json byte[] was null.");
+return r;
+}
+
+LOG.debug("Json created: {}", new String(json));
+
+return r.newRecord(r.topic(), r.kafkaPartition(), r.keySchema(),
r.key(),
+Schema.BYTES_SCHEMA, json, r.timestamp());
+} else {
+LOG.debug("Incoming record with a null value or a null schema,
nothing to be done.");
+return r;
+}
+}
+
+@Override
+public ConfigDef config() {
+return JsonConverterConfig.configDef();
+}
+
+@Override
+public void close() {
+//NOOP
+}
+
+@Override
+public void configure(Map configs) {
+jsonConverter = new JsonConverter();
+Map conf = new HashMap<>(configs);
+conf.put(ConverterConfig.TYPE_CONFIG, ConverterType.VALUE.getName());
+jsonConverter.configure(conf);
+}
+}
\ No newline at end of file
diff --git
a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransformTest.java
b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransformTest.java
new file mode 100644
index 000..159c7d7
--- /dev/null
+++
b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransformTest.java
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the Licen
[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated (dd8f526 -> dc8f444)
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch camel-kafka-connector-0.7.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from dd8f526 Upgrade to 3.7.1 and regen
new 17b59c5 Fixed a minor issue in a test in
SinkPojoToSchemaAndStructTransformTest
new dc8f444 Added SchemaAndStructToJsonTransform fix #843
The 2 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:
.../transforms/SchemaAndStructToJsonTransform.java | 77 ++
...ava => SchemaAndStructToJsonTransformTest.java} | 45 +++--
.../SinkPojoToSchemaAndStructTransformTest.java| 3 +-
3 files changed, 101 insertions(+), 24 deletions(-)
create mode 100644
core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java
copy
core/src/test/java/org/apache/camel/kafkaconnector/transforms/{SinkPojoToSchemaAndStructTransformTest.java
=> SchemaAndStructToJsonTransformTest.java} (62%)
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.1 created (now 3650693)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 3650693 (tag) tagging 4fe8c1df5ed7480640043bd95e6d14fd8284d54e (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Sun Jan 24 15:18:10 2021 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.7.1 --- No new revisions were added by this update.
[camel-kafka-connector] tag camel-kafka-connector-0.7.1 updated (3650693 -> 31475c2)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.1 was modified! *** from 3650693 (tag) to 31475c2 (commit) from 4fe8c1d [maven-release-plugin] prepare release camel-kafka-connector-0.7.1 add 94892b1 [maven-release-plugin] prepare for next development iteration add 31475c2 [after release perform chore]: regen catalog descriptors with new version No new revisions were added by this update. Summary of changes: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- .../src/generated/resources/connectors/camel-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json | 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json| 2 +- .../src/generated/resources/connectors/camel-as2-source.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-source.json| 2 +- .../resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../generated/resources/connectors/camel-atomix-multimap-sink.json| 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink.json| 2 +- .../generated/resources/connectors/camel-aws-ddbstream-source.json| 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-ecs-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-eks-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-iam-sink.json| 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-kms-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-lambda-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-mq-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-msk-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink.json
[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated (e3e4673 -> dc8f444)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. discard e3e4673 [maven-release-plugin] prepare for next development iteration omit ee75381 [after release perform chore]: regen catalog descriptors with new version omit 4fe8c1d [maven-release-plugin] prepare release camel-kafka-connector-0.7.1 This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/camel-kafka-connector-0.7.x (dc8f444) \ O -- O -- O (e3e4673) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- .../src/generated/resources/connectors/camel-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json | 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json| 2 +- .../src/generated/resources/connectors/camel-as2-source.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-source.json| 2 +- .../resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../generated/resources/connectors/camel-atomix-multimap-sink.json| 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink.json| 2 +- .../generated/resources/connectors/camel-aws-ddbstream-source.json| 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-ecs-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-eks-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-iam-sink.json| 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-kms-sink.json| 2 +
[camel-kafka-connector] annotated tag camel-kafka-connector-0.7.1 created (now 1fbfc86)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 1fbfc86 (tag) tagging d4b722b1e3ba8faeeefdf0a13df12c503c00946f (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Sun Jan 24 16:59:49 2021 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.7.1 --- No new revisions were added by this update.
[camel-kafka-connector] tag camel-kafka-connector-0.7.1 updated (1fbfc86 -> bc6ddb7)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.1 was modified! *** from 1fbfc86 (tag) to bc6ddb7 (commit) from d4b722b [maven-release-plugin] prepare release camel-kafka-connector-0.7.1 new bc6ddb7 [after release perform chore]: regen catalog descriptors with new version The 1 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-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json| 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-source.json| 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json| 2 +- .../src/generated/resources/connectors/camel-atmos-source.json | 2 +- .../generated/resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-multimap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-cw-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddbstream-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ecs-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-eks-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-iam-sink.json | 2 +- .../generated/resources/connectors/camel-aws-kinesis-firehose-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-source.json| 2 +- .../src/generated/resources/connectors/camel-aws-kms-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-lambda-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-mq-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-msk-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-sdb-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ses-si
[camel-kafka-connector] tag camel-kafka-connector-0.7.1 updated (31475c2 -> ee75381)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.1 was modified! *** from 31475c2 (commit) to ee75381 (commit) discard 31475c2 [after release perform chore]: regen catalog descriptors with new version discard 94892b1 [maven-release-plugin] prepare for next development iteration add ee75381 [after release perform chore]: regen catalog descriptors with new version This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the tag 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 (31475c2) \ N -- N -- N refs/tags/camel-kafka-connector-0.7.1 (ee75381) 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. No new revisions were added by this update. Summary of changes: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-activemq-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-ws-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-wss-kafka-connector/pom.xml | 2 +- connectors/camel-amqp-kafka-connector/pom.xml | 2 +- connectors/camel-apns-kafka-connector/pom.xml | 2 +- connectors/camel-arangodb-kafka-connector/pom.xml | 2 +- connectors/camel-as2-kafka-connector/pom.xml | 2 +- connectors/camel-asterisk-kafka-connector/pom.xml | 2 +- connectors/camel-atlasmap-kafka-connector/pom.xml | 2 +- connectors/camel-atmos-kafka-connector/pom.xml| 2 +- connectors/camel-atmosphere-websocket-kafka-connector/pom.xml | 2 +- connectors/camel-atom-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-map-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-messaging-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-multimap-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-queue-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-set-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-value-kafka-connector/pom.xml | 2 +- connectors/camel-avro-kafka-connector/pom.xml | 2 +- connectors/camel-aws-cw-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddbstream-kafka-connector/pom.xml| 2 +- connectors/camel-aws-ec2-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ecs-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eks-kafka-connector/pom.xml | 2 +- connectors/camel-aws-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kms-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-kafka-connector/pom.xml | 2 +- connectors/camel-aws-mq-kafka-connector/pom.xml | 2 +- connectors/camel-aws-msk-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sdb-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-kafka-connector/pom.xml | 2 +- connectors/camel-aws-swf-kafka-connector/pom.xml | 2 +- connectors/camel-aws-translate-kafka-connector/pom.xml| 2 +- connectors/cam
[camel-kafka-connector] branch camel-kafka-connector-0.7.x updated (31475c2 -> e3e4673)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.7.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. omit 31475c2 [after release perform chore]: regen catalog descriptors with new version omit 94892b1 [maven-release-plugin] prepare for next development iteration new ee75381 [after release perform chore]: regen catalog descriptors with new version new e3e4673 [maven-release-plugin] prepare for next development iteration 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 (31475c2) \ N -- N -- N refs/heads/camel-kafka-connector-0.7.x (e3e4673) 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 2 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-kafka-connector] tag camel-kafka-connector-0.7.1 deleted (was ee75381)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.7.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.7.1 was deleted! *** was ee75381 [after release perform chore]: regen catalog descriptors with new version This change permanently discards the following revisions: discard ee75381 [after release perform chore]: regen catalog descriptors with new version discard 4fe8c1d [maven-release-plugin] prepare release camel-kafka-connector-0.7.1
[camel-kafka-connector] branch master updated: Updates SSH tests to Camel's 3.7 test infra interfaces
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 524fc20 Updates SSH tests to Camel's 3.7 test infra interfaces
524fc20 is described below
commit 524fc20b021a0e683a1e32b7a5f66203bb4b0484
Author: Otavio Rodolfo Piske
AuthorDate: Fri Jan 15 08:33:55 2021 +0100
Updates SSH tests to Camel's 3.7 test infra interfaces
---
.../SshProperties.java}| 32 --
.../ssh/services/SshLocalContainerService.java | 15 +-
.../ssh/services/SshRemoteService.java | 13 +++--
.../kafkaconnector/ssh/services/SshService.java| 13 ++---
4 files changed, 31 insertions(+), 42 deletions(-)
diff --git
a/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java
b/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/common/SshProperties.java
similarity index 58%
copy from
tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java
copy to
tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/common/SshProperties.java
index cb5de9c..920e5fa 100644
---
a/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java
+++
b/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/common/SshProperties.java
@@ -15,35 +15,13 @@
* limitations under the License.
*/
-package org.apache.camel.kafkaconnector.ssh.services;
+package org.apache.camel.kafkaconnector.ssh.common;
-public class SshRemoteService implements SshService {
+public final class SshProperties {
+public static final String SSH_HOST = "ssh.host";
+public static final String SSH_PORT = "ssh.port";
-private static final int DEFAULT_SSH_PORT = 22;
+private SshProperties() {
-@Override
-public void initialize() {
-
-}
-
-@Override
-public void shutdown() {
-
-}
-
-@Override
-public int getSshPort() {
-String strPort = System.getProperty("ssh.port");
-
-if (strPort != null) {
-return Integer.parseInt(strPort);
-}
-
-return DEFAULT_SSH_PORT;
-}
-
-@Override
-public String getSshHost() {
-return System.getProperty("ssh.host");
}
}
diff --git
a/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java
b/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java
index 3ecc73c..aca073c 100644
---
a/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java
+++
b/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java
@@ -17,10 +17,12 @@
package org.apache.camel.kafkaconnector.ssh.services;
+import org.apache.camel.kafkaconnector.ssh.common.SshProperties;
+import org.apache.camel.test.infra.common.services.ContainerService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class SshLocalContainerService implements SshService {
+public class SshLocalContainerService implements SshService,
ContainerService {
private static final Logger LOG =
LoggerFactory.getLogger(SshLocalContainerService.class);
private SshContainer container;
@@ -40,6 +42,12 @@ public class SshLocalContainerService implements SshService {
}
@Override
+public void registerProperties() {
+System.setProperty(SshProperties.SSH_PORT,
String.valueOf(getSshPort()));
+System.setProperty(SshProperties.SSH_HOST, getSshHost());
+}
+
+@Override
public void initialize() {
container.start();
LOG.info("SSH server running at address {}", getSshEndpoint());
@@ -50,4 +58,9 @@ public class SshLocalContainerService implements SshService {
LOG.info("Stopping the Ssh container");
container.stop();
}
+
+@Override
+public SshContainer getContainer() {
+return container;
+}
}
diff --git
a/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java
b/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java
index cb5de9c..4bac3d8 100644
---
a/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java
+++
b/tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java
@@ -17,13 +17,20 @@
package org.apache.camel.kafkaconnector.ssh.services;
+import org.apache.camel.kafkaconnector.ssh.common.SshProperties;
+
public class SshRemoteService implements SshService {
private static final int DEFAULT
[camel-kafka-connector] branch master updated: Added new S3 v2 manual test that supports testing w/ large files
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 1b047d3 Added new S3 v2 manual test that supports testing w/ large
files
1b047d3 is described below
commit 1b047d3cc23c6d2a684cd8fc85a920c5ae0962ce
Author: Otavio Rodolfo Piske
AuthorDate: Wed Dec 16 10:19:02 2020 +0100
Added new S3 v2 manual test that supports testing w/ large files
---
.../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 102 +
1 file changed, 83 insertions(+), 19 deletions(-)
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/source/CamelSourceAWSS3ITCase.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/source/CamelSourceAWSS3ITCase.java
index 6ad128b..5f571b7 100644
---
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/source/CamelSourceAWSS3ITCase.java
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/source/CamelSourceAWSS3ITCase.java
@@ -21,6 +21,7 @@ import java.io.File;
import java.net.URL;
import java.util.Properties;
import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
import org.apache.camel.kafkaconnector.aws.v2.clients.AWSSDKClientUtils;
import org.apache.camel.kafkaconnector.common.AbstractKafkaTest;
@@ -54,6 +55,11 @@ import static org.junit.jupiter.api.Assertions.fail;
public class CamelSourceAWSS3ITCase extends AbstractKafkaTest {
private static final Logger LOG =
LoggerFactory.getLogger(CamelSourceAWSS3ITCase.class);
+@FunctionalInterface
+private interface SendFunction {
+void send();
+}
+
@RegisterExtension
AWSService service = AWSServiceFactory.createS3Service();
@@ -61,7 +67,7 @@ public class CamelSourceAWSS3ITCase extends AbstractKafkaTest
{
private String bucketName;
private volatile int received;
-private final int expect = 10;
+private int expect;
@Override
protected String[] getConnectorsInTest() {
@@ -106,35 +112,53 @@ public class CamelSourceAWSS3ITCase extends
AbstractKafkaTest {
return true;
}
-public void runTest(ConnectorPropertyFactory connectorPropertyFactory)
throws ExecutionException, InterruptedException {
+public void runTest(ConnectorPropertyFactory connectorPropertyFactory,
SendFunction sendFunction)
+throws ExecutionException, InterruptedException {
+
connectorPropertyFactory.log();
getKafkaConnectService().initializeConnector(connectorPropertyFactory);
-LOG.debug("Putting S3 objects");
-for (int i = 0; i < expect; i++) {
-String name = "file" + i + ".test";
-LOG.debug("Trying to read file {}", name);
-URL fileResource = this.getClass().getResource(name);
-LOG.debug("Found file at {}", fileResource.getPath());
-String file = fileResource.getFile();
-LOG.debug("Using file {}", file);
-
-LOG.trace("Putting file {}", file);
-PutObjectRequest putObjectRequest = PutObjectRequest.builder()
-.bucket(bucketName)
-.key(name)
-.build();
+sendFunction.send();
-awsS3Client.putObject(putObjectRequest, new File(file).toPath());
-}
LOG.debug("Done putting S3S objects");
LOG.debug("Creating the consumer ...");
KafkaClient kafkaClient = new
KafkaClient<>(getKafkaService().getBootstrapServers());
kafkaClient.consume(TestUtils.getDefaultTestTopic(this.getClass()),
this::checkRecord);
LOG.debug("Created the consumer ...");
+}
+
+public void runTest(ConnectorPropertyFactory connectorPropertyFactory)
throws ExecutionException, InterruptedException {
+runTest(connectorPropertyFactory, this::sendFiles);
+}
+
+private void sendFilesFromPath(File path) {
+LOG.debug("Putting S3 objects");
+
+File[] files = path.listFiles();
+expect = files.length;
+
+if (files.length == 0) {
+fail("Not enough files to run the test");
+}
+
+for (File file : files) {
+LOG.debug("Trying to read file {}", file.getName());
+
+PutObjectRequest putObjectRequest = PutObjectRequest.builder()
+.bucket(bucketName)
+.key(file.getName())
+.build();
+
+awsS3Client.putObject(putObjectRequest, file.toPath());
+}
+}
+
+private void sendFiles() {
+URL resourceDir = this.getClass().getResource(".");
+
[camel-kafka-connector] branch main updated: Added documentation on how to run Salesforce integration tests.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new 4e07d45 Added documentation on how to run Salesforce integration tests. 4e07d45 is described below commit 4e07d45a36701b67bbb5d771a6f7d5b0a08b0722 Author: Andrea Tarocchi AuthorDate: Wed Jun 16 17:19:25 2021 +0200 Added documentation on how to run Salesforce integration tests. --- .../ROOT/pages/contributor-guide/testing.adoc | 41 +++--- 1 file changed, 37 insertions(+), 4 deletions(-) diff --git a/docs/modules/ROOT/pages/contributor-guide/testing.adoc b/docs/modules/ROOT/pages/contributor-guide/testing.adoc index cc82ecd..9b87a62 100644 --- a/docs/modules/ROOT/pages/contributor-guide/testing.adoc +++ b/docs/modules/ROOT/pages/contributor-guide/testing.adoc @@ -5,7 +5,6 @@ == Table of Contents * <> -* <> * <> [#running-the-tests] @@ -15,7 +14,14 @@ The most basic way of running the tests is to do so as part of the build. The co [source,bash] -mvn -DskipIntegrationTests=false clean verify package +mvn -DskipIntegrationTests=false clean verify + + +To also run the slow integration tests use: + +[source,bash] + +mvn -DskipIntegrationTests=false -Denable.slow.tests=true clean verify The test code in the project is rather flexible and allow a different range of options regarding the environment, @@ -23,11 +29,11 @@ tools, etc that can be used. For example, to use an external (remote) Kafka brok [source,bash] -mvn -Dkafka.bootstrap.servers=host1:port -Dkafka.instance.type=remote -DskipIntegrationTests=false clean verify package +mvn -Dkafka.bootstrap.servers=host1:port -Dkafka.instance.type=remote -DskipIntegrationTests=false clean verify [#running-the-tests-remotely] -== Running The Tests Remotely +=== Running The Tests Remotely Not only Kafka, but also other external infrastructure can be used for the tests. To do so, you must set properties for the services that you want to run. This causes the tests to not launch the local container and use existing @@ -81,6 +87,33 @@ these flags along with others that are specific to that service: * it.test.salesforce.enable * it.test.slack.enable + Salesforce Test + +Configure your Salesforce developer account as described here https://github.com/apache/camel-examples/blob/main/examples/salesforce-consumer/README.adoc#configuring-salesforce + +Before running the tests be sure to: + +- Run the Salesforce CLI container: + +[source,bash] + +$ docker run --rm --name salesforce-cli -it -v /path/to/sfdx:/root/.sfdx salesforce/salesforcedx + + +- Within the container, use the following command to login: + +[source,bash] + +$ sfdx force:auth:device:login -s -d -i + + +- Now you should be able to run all integration tests including Salesforce tests with: + +[source,bash] + +$ mvn -DskipIntegrationTests=false -Dit.test.salesforce.enable=true clean verify + + === Performance Tests There is also a reference test implementation for checking the performance and resource usage in some situations.
[camel-kafka-connector] branch camel-kafka-connector-0.10.x updated: Added documentation on how to run Salesforce integration tests.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.10.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-0.10.x by this push: new 6be61e7 Added documentation on how to run Salesforce integration tests. 6be61e7 is described below commit 6be61e7824a5b84acf89130a2ae732ec62a4d000 Author: Andrea Tarocchi AuthorDate: Wed Jun 16 17:19:25 2021 +0200 Added documentation on how to run Salesforce integration tests. --- .../ROOT/pages/contributor-guide/testing.adoc | 41 +++--- 1 file changed, 37 insertions(+), 4 deletions(-) diff --git a/docs/modules/ROOT/pages/contributor-guide/testing.adoc b/docs/modules/ROOT/pages/contributor-guide/testing.adoc index cc82ecd..9b87a62 100644 --- a/docs/modules/ROOT/pages/contributor-guide/testing.adoc +++ b/docs/modules/ROOT/pages/contributor-guide/testing.adoc @@ -5,7 +5,6 @@ == Table of Contents * <> -* <> * <> [#running-the-tests] @@ -15,7 +14,14 @@ The most basic way of running the tests is to do so as part of the build. The co [source,bash] -mvn -DskipIntegrationTests=false clean verify package +mvn -DskipIntegrationTests=false clean verify + + +To also run the slow integration tests use: + +[source,bash] + +mvn -DskipIntegrationTests=false -Denable.slow.tests=true clean verify The test code in the project is rather flexible and allow a different range of options regarding the environment, @@ -23,11 +29,11 @@ tools, etc that can be used. For example, to use an external (remote) Kafka brok [source,bash] -mvn -Dkafka.bootstrap.servers=host1:port -Dkafka.instance.type=remote -DskipIntegrationTests=false clean verify package +mvn -Dkafka.bootstrap.servers=host1:port -Dkafka.instance.type=remote -DskipIntegrationTests=false clean verify [#running-the-tests-remotely] -== Running The Tests Remotely +=== Running The Tests Remotely Not only Kafka, but also other external infrastructure can be used for the tests. To do so, you must set properties for the services that you want to run. This causes the tests to not launch the local container and use existing @@ -81,6 +87,33 @@ these flags along with others that are specific to that service: * it.test.salesforce.enable * it.test.slack.enable + Salesforce Test + +Configure your Salesforce developer account as described here https://github.com/apache/camel-examples/blob/main/examples/salesforce-consumer/README.adoc#configuring-salesforce + +Before running the tests be sure to: + +- Run the Salesforce CLI container: + +[source,bash] + +$ docker run --rm --name salesforce-cli -it -v /path/to/sfdx:/root/.sfdx salesforce/salesforcedx + + +- Within the container, use the following command to login: + +[source,bash] + +$ sfdx force:auth:device:login -s -d -i + + +- Now you should be able to run all integration tests including Salesforce tests with: + +[source,bash] + +$ mvn -DskipIntegrationTests=false -Dit.test.salesforce.enable=true clean verify + + === Performance Tests There is also a reference test implementation for checking the performance and resource usage in some situations.
[camel-kafka-connector] annotated tag camel-kafka-connector-0.10.1 created (now 6bb72dd)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.10.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 6bb72dd (tag) tagging 785f416ebb190049ab8364814d994f08523fc50e (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Wed Jun 16 23:43:35 2021 +0200 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.10.1 --- No new revisions were added by this update.
[camel-kafka-connector] 02/02: Removed camel-apns-kafka-connector.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 9d1f1379ea3c59f068448c71384e866392c18597
Author: Andrea Tarocchi
AuthorDate: Tue Jun 8 23:39:06 2021 +0200
Removed camel-apns-kafka-connector.
---
connectors/camel-apns-kafka-connector/pom.xml | 139 --
.../descriptors/connector-sink.properties | 1 -
.../descriptors/connector-source.properties| 1 -
.../src/generated/resources/camel-apns-sink.json | 52 --
.../src/generated/resources/camel-apns-source.json | 192 ---
.../src/main/assembly/package.xml | 56 --
.../main/docs/camel-apns-kafka-sink-connector.adoc | 57 --
.../docs/camel-apns-kafka-source-connector.adoc| 75
.../examples/CamelApnsSinkConnector.properties | 33
.../examples/CamelApnsSourceConnector.properties | 33
.../apns/CamelApnsSinkConnector.java | 35
.../apns/CamelApnsSinkConnectorConfig.java | 66 ---
.../kafkaconnector/apns/CamelApnsSinkTask.java | 39
.../apns/CamelApnsSourceConnector.java | 35
.../apns/CamelApnsSourceConnectorConfig.java | 140 --
.../kafkaconnector/apns/CamelApnsSourceTask.java | 39
.../src/main/resources/META-INF/LICENSE.txt| 203 -
.../src/main/resources/META-INF/NOTICE.txt | 11 --
connectors/pom.xml | 1 -
19 files changed, 1208 deletions(-)
diff --git a/connectors/camel-apns-kafka-connector/pom.xml
b/connectors/camel-apns-kafka-connector/pom.xml
deleted file mode 100644
index e42aa06..000
--- a/connectors/camel-apns-kafka-connector/pom.xml
+++ /dev/null
@@ -1,139 +0,0 @@
-
-
-http://maven.apache.org/POM/4.0.0;
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
- 4.0.0
-
-org.apache.camel.kafkaconnector
-connectors
-0.11.0-SNAPSHOT
-
- camel-apns-kafka-connector
- Camel-Kafka-Connector :: apns
- Camel Kafka Connector for apns
-
-
-
- org.apache.kafka
- connect-api
- provided
-
-
- org.apache.kafka
- connect-transforms
- provided
-
-
-
- org.apache.camel
- camel-apns
-
-
-
- org.apache.camel.kafkaconnector
- camel-kafka-connector
-
-
- org.apache.camel
- camel-jackson
-
-
-
-
-
-
-org.apache.maven.plugins
-maven-surefire-plugin
-${version.maven.surefire.plugin}
-
- false
-
-
-
-org.apache.maven.plugins
-maven-jar-plugin
-${version.maven.jar}
-
-
-
-
true
-
true
-
-
-
-
-
-org.apache.maven.plugins
-maven-compiler-plugin
-2.5.1
-true
-
- 1.8
- 1.8
-
-
-
-maven-assembly-plugin
-2.5.3
-
-
-src/main/assembly/package.xml
-
-
-
-
-make-assembly
-package
-
- single
-
-
-
-
-
-
-
-
-
-
- atlassian-public
- https://packages.atlassian.com/maven-external
- Atlassian Public Repo
-
-false
-
-
-true
-
-
-
-
- jboss.thirdparty
- JBoss Thirdparty Repository
-
https://repository.jboss.org/nexus/service/local/repositories/thirdparty-releases/content/
-
-false
-
-
-true
-
-
-
-
-
diff --git
a/connectors/camel-apns-kafka-connector/src/generated/descriptors/connector-sink.properties
b/connectors/camel-apns-kafka-connector/src/generated/descriptors/connector-sink.properties
deleted file mode 100644
index 2b0d5e2..000
---
a/connectors/camel-apns-kafka-connector/src/generated/descriptors/connector-sink.properties
+++ /dev/null
@@ -1 +0,0 @@
-camel-apns-sink
\ No newline at end of file
diff --git
a/connectors/camel-apns-kafka-connector/src/generated/descriptors/connector-source.properties
b/connectors/camel-apns-kafka-connector/src/generated/descriptors/connector-source.properties
deleted file mode 100644
index 05d5696..000
---
a/connectors/camel-apns-kafka-connector/src/generated/descriptors/connector-source.properties
+++ /dev/null
@@ -1 +0,0 @@
-camel-apns-source
\ No newline at end of file
diff --git
a/connectors/camel-apns-kafka-connector/src/generated/resources/camel-apns-sink.json
b/connectors/camel-apns-kafka-connector/src/generated/resources/camel-apns-sink.json
deleted file mode 100644
index b4f
[camel-kafka-connector] branch main updated (e7c6c69 -> 9d1f137)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from e7c6c69 Updated CHANGELOG.md new 68d5690 Some documentation link fixes. new 9d1f137 Removed camel-apns-kafka-connector. The 2 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: connectors/camel-apns-kafka-connector/pom.xml | 139 - .../descriptors/connector-sink.properties | 1 - .../descriptors/connector-source.properties| 1 - .../src/generated/resources/camel-apns-sink.json | 52 - .../src/generated/resources/camel-apns-source.json | 192 - .../src/main/assembly/package.xml | 56 - .../main/docs/camel-apns-kafka-sink-connector.adoc | 57 -- .../docs/camel-apns-kafka-source-connector.adoc| 75 --- .../examples/CamelApnsSinkConnector.properties | 33 --- .../examples/CamelApnsSourceConnector.properties | 33 --- .../apns/CamelApnsSinkConnector.java | 35 .../apns/CamelApnsSinkConnectorConfig.java | 66 -- .../kafkaconnector/apns/CamelApnsSinkTask.java | 39 .../apns/CamelApnsSourceConnector.java | 35 .../apns/CamelApnsSourceConnectorConfig.java | 140 - .../kafkaconnector/apns/CamelApnsSourceTask.java | 39 .../src/main/resources/META-INF/LICENSE.txt| 203 -- .../src/main/resources/META-INF/NOTICE.txt | 11 - connectors/pom.xml | 1 - docs/modules/ROOT/nav.adoc | 2 +- .../camel-activemq-kafka-sink-connector.adoc | 204 -- .../camel-activemq-kafka-source-connector.adoc | 205 -- .../connectors/camel-ahc-kafka-sink-connector.adoc | 78 --- .../camel-ahc-ws-kafka-sink-connector.adoc | 79 --- .../camel-ahc-ws-kafka-source-connector.adoc | 79 --- .../camel-ahc-wss-kafka-sink-connector.adoc| 79 --- .../camel-ahc-wss-kafka-source-connector.adoc | 79 --- .../camel-amqp-kafka-sink-connector.adoc | 201 -- .../camel-amqp-kafka-source-connector.adoc | 201 -- .../camel-apns-kafka-sink-connector.adoc | 61 -- .../camel-apns-kafka-source-connector.adoc | 79 --- .../camel-arangodb-kafka-sink-connector.adoc | 78 --- .../connectors/camel-as2-kafka-sink-connector.adoc | 88 .../camel-as2-kafka-source-connector.adoc | 89 .../camel-asterisk-kafka-sink-connector.adoc | 63 -- .../camel-asterisk-kafka-source-connector.adoc | 64 -- .../camel-atlasmap-kafka-sink-connector.adoc | 66 -- .../camel-atmos-kafka-sink-connector.adoc | 72 --- .../camel-atmos-kafka-source-connector.adoc| 74 --- ...-atmosphere-websocket-kafka-sink-connector.adoc | 71 --- ...tmosphere-websocket-kafka-source-connector.adoc | 90 .../camel-atom-kafka-source-connector.adoc | 85 .../camel-atomix-map-kafka-sink-connector.adoc | 88 .../camel-atomix-map-kafka-source-connector.adoc | 90 ...amel-atomix-messaging-kafka-sink-connector.adoc | 90 ...el-atomix-messaging-kafka-source-connector.adoc | 92 - ...camel-atomix-multimap-kafka-sink-connector.adoc | 88 .../camel-atomix-queue-kafka-sink-connector.adoc | 84 .../camel-atomix-queue-kafka-source-connector.adoc | 86 .../camel-atomix-set-kafka-sink-connector.adoc | 86 .../camel-atomix-set-kafka-source-connector.adoc | 88 .../camel-atomix-value-kafka-sink-connector.adoc | 86 .../camel-atomix-value-kafka-source-connector.adoc | 88 .../camel-avro-kafka-sink-connector.adoc | 75 --- .../camel-avro-kafka-source-connector.adoc | 77 --- ...l-aws-secrets-manager-kafka-sink-connector.adoc | 88 .../camel-aws2-athena-kafka-sink-connector.adoc| 114 --- .../camel-aws2-cw-kafka-sink-connector.adoc| 90 .../camel-aws2-ddb-kafka-sink-connector.adoc | 96 - ...amel-aws2-ddbstream-kafka-source-connector.adoc | 106 -- .../camel-aws2-ec2-kafka-sink-connector.adoc | 86 .../camel-aws2-ecs-kafka-sink-connector.adoc | 86 .../camel-aws2-eks-kafka-sink-connector.adoc | 86 ...amel-aws2-eventbridge-kafka-sink-connector.adoc | 88 .../camel-aws2-iam-kafka-sink-connector.adoc | 86 ...aws2-kinesis-firehose-kafka-sink-connector.adoc | 86
[camel-website] branch valdar-patch-1 created (now 5708d45)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git. at 5708d45 Changed the link to Componend DSL to a statick github file No new revisions were added by this update.
[camel-website] branch main updated: Changed the link to Componend DSL to a statick github file (#587)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-website.git The following commit(s) were added to refs/heads/main by this push: new 35fd35a Changed the link to Componend DSL to a statick github file (#587) 35fd35a is described below commit 35fd35a6399afbcec34600cca01253a1fcba45df Author: Andrea Tarocchi AuthorDate: Mon Jun 7 22:15:36 2021 +0200 Changed the link to Componend DSL to a statick github file (#587) That quarkus doc page from version 1.0.0.-CR3 was deleted. --- content/blog/2020/07/camel-quarkus-release-1.0.0-CR3/index.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/content/blog/2020/07/camel-quarkus-release-1.0.0-CR3/index.md b/content/blog/2020/07/camel-quarkus-release-1.0.0-CR3/index.md index bcaeddb..977994c 100644 --- a/content/blog/2020/07/camel-quarkus-release-1.0.0-CR3/index.md +++ b/content/blog/2020/07/camel-quarkus-release-1.0.0-CR3/index.md @@ -17,7 +17,7 @@ Here are some highlights of Camel Quarkus 1.0.0-CR3. The following new extensions were added: * [AWS 2 Athena](/camel-quarkus/latest/reference/extensions/aws2-athena.html) -* [Component DSL](/camel-quarkus/latest/reference/extensions/componentdsl.html) +* [Component DSL](https://github.com/apache/camel-quarkus/blob/1.0.0-CR3/docs/modules/ROOT/pages/extensions/componentdsl.adoc) * [JOLT](/camel-quarkus/latest/reference/extensions/jolt.html) * [JTA](/camel-quarkus/latest/reference/extensions/jta.html) * [OpenApi Java](/camel-quarkus/latest/reference/extensions/openapi-java.html)
[camel-quarkus] branch main updated (7547d0e -> e452faf)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git. from 7547d0e Improve KafkaClientFactory integration add e452faf fixed #2736 No new revisions were added by this update. Summary of changes: docs/modules/ROOT/pages/contributor-guide/release-guide.adoc | 9 - 1 file changed, 8 insertions(+), 1 deletion(-)
[camel-website] branch main updated: Fixed Camel Kafka Connector links after doc refactor of the subproject. (#588)
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-website.git
The following commit(s) were added to refs/heads/main by this push:
new df6f42b Fixed Camel Kafka Connector links after doc refactor of the
subproject. (#588)
df6f42b is described below
commit df6f42b742ef06242e1edb8a187ac254d5a3ec03
Author: Andrea Tarocchi
AuthorDate: Thu Jun 10 22:24:56 2021 +0200
Fixed Camel Kafka Connector links after doc refactor of the subproject.
(#588)
---
content/blog/2020/09/Camel-kafka-connector-050-Whatsnew/index.md | 2 +-
content/blog/2020/12/CKC-idempotency-070/index.md| 2 +-
content/blog/2021/01/VSCode-LanguageSupport-0.0.30/index.md | 2 +-
data/release-categories.yaml | 2 +-
layouts/partials/releases/camel-kafka-connector.html | 2 +-
5 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/content/blog/2020/09/Camel-kafka-connector-050-Whatsnew/index.md
b/content/blog/2020/09/Camel-kafka-connector-050-Whatsnew/index.md
index 2ba1f7a..615ab95 100644
--- a/content/blog/2020/09/Camel-kafka-connector-050-Whatsnew/index.md
+++ b/content/blog/2020/09/Camel-kafka-connector-050-Whatsnew/index.md
@@ -43,7 +43,7 @@ The documentation of each connector (source/sink or both) now
contains reference
- Aggregation Strategies list available in the connector as out of the box
solutions
On the Archetypes side: the archetype provided to extend the current
connectors is now able to use a parameter to specify what connector you want to
extend.
-More information available at [Camel-Kafka-connector archetype
documentation](/camel-kafka-connector/latest/archetypes.html).
+More information available at [Camel-Kafka-connector archetype
documentation](/camel-kafka-connector/latest/user-guide/extending-connector/index.html).
We added also a troubleshooting section in our documentation, to be able to
debug and use the connectors in the best way possible.
diff --git a/content/blog/2020/12/CKC-idempotency-070/index.md
b/content/blog/2020/12/CKC-idempotency-070/index.md
index 66afab6..17f4a77 100644
--- a/content/blog/2020/12/CKC-idempotency-070/index.md
+++ b/content/blog/2020/12/CKC-idempotency-070/index.md
@@ -66,7 +66,7 @@ Some of the options can be used with their default value, in
this example we're
### A real example
-The best way to show how the idempotency feature works, in
camel-kafka-connector, it's through an example. We'll use the [AWS2-S3 Source
connector](/camel-kafka-connector/latest/connectors/camel-aws2-s3-kafka-source-connector.html)
+The best way to show how the idempotency feature works, in
camel-kafka-connector, it's through an example. We'll use the [AWS2-S3 Source
connector](/camel-kafka-connector/latest/reference/connectors/camel-aws2-s3-kafka-source-connector.html)
As first step you'll need to fully build the [Camel-Kafka-connector
project](https://github.com/apache/camel-kafka-connector) and install the
connectors/camel-aws2-s3-kafka-connector zip package in your Kafka Broker
plugin.path. Once the connector is in the plugin.path location, just unzip it.
We describe how to build and unpack in the next steps:
diff --git a/content/blog/2021/01/VSCode-LanguageSupport-0.0.30/index.md
b/content/blog/2021/01/VSCode-LanguageSupport-0.0.30/index.md
index 6f6ad79..19a3c38 100644
--- a/content/blog/2021/01/VSCode-LanguageSupport-0.0.30/index.md
+++ b/content/blog/2021/01/VSCode-LanguageSupport-0.0.30/index.md
@@ -18,7 +18,7 @@ The Camel Kafka Connector catalog has been upgraded from
0.6.0 to 0.7.0.
Completion for Basic Configuration
-Some properties are not part of the Camel catalog material, neither of the
[Kafka Connect](https://kafka.apache.org/documentation/#connectconfigs)
framework and applies to all Camel Kafka connectors. They are the [Basic
Configuration
properties](/camel-kafka-connector/latest/basic-configuration.html).
+Some properties are not part of the Camel catalog material, neither of the
[Kafka Connect](https://kafka.apache.org/documentation/#connectconfigs)
framework and applies to all Camel Kafka connectors. They are the [Basic
Configuration
properties](/camel-kafka-connector/latest/user-guide/basic-configuration.html).
Completion is now available for these properties:
diff --git a/data/release-categories.yaml b/data/release-categories.yaml
index 6158aa1..2346cb9 100644
--- a/data/release-categories.yaml
+++ b/data/release-categories.yaml
@@ -83,7 +83,7 @@ camel-kafka-connector:
filename_format: 'camel-kafka-connector-{version}-src.zip'
- name: 'Binaries'
title: 'Connectors download list'
- link: '/camel-kafka-connector/latest/connectors.html'
+ link: '/camel-kafka-connector/latest/reference/index.html'
camel-quarkus:
id: 'camel-quarkus'
name: 'Apache Camel Quarkus'
diff --git a/layouts/partials/releases
[camel-kafka-connector] branch camel-kafka-connector-0.10.x updated: Fixed internal doc links.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.10.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-0.10.x by this push: new 11d64c6 Fixed internal doc links. 11d64c6 is described below commit 11d64c632ea4eef30dae3d281cbc7c71dee60ebc Author: Andrea Tarocchi AuthorDate: Thu Jun 10 21:22:11 2021 +0200 Fixed internal doc links. --- docs/modules/ROOT/pages/contributor-guide/release-guide.adoc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc b/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc index 8b550d3..2b07d69 100644 --- a/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc +++ b/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc @@ -3,10 +3,10 @@ :page-aliases: release-guide.adoc The process is _mutatis mutandis_ the same as for the main Apache Camel repository - see the -https://camel.apache.org/manual/latest/release-guide.html[Release guide] page of the Camel documentation. +xref:latest@manual::release-guide.adoc[Release guide] page of the Camel documentation. Here, just a sketch of the repeating part, after you have performed the initial setup following the -https://camel.apache.org/manual/latest/release-guide.html[Camel Release guide]. In particular the section about setting up your maven environment as described in https://camel.apache.org/manual/latest/release-guide.html#ReleaseGuide-MavenSetup[Camel Release Maven Setup]. +xref:latest@manual::release-guide.adoc[Camel Release guide]. In particular the section about setting up your maven environment as described in xref:latest@manual::release-guide.adoc#ReleaseGuide-MavenSetup[Camel Release Maven Setup]. == Pre release tasks
svn commit: r48461 - in /release/camel/camel-kafka-connector/0.10.1: ./ camel-kafka-connector-0.10.1-src.zip camel-kafka-connector-0.10.1-src.zip.asc camel-kafka-connector-0.10.1-src.zip.sha512
Author: valdar Date: Tue Jun 22 16:56:15 2021 New Revision: 48461 Log: Camel Kafka Connector 0.10.1 import. Added: release/camel/camel-kafka-connector/0.10.1/ release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip (with props) release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip.asc (with props) release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip.sha512 Added: release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip.sha512 == --- release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/0.10.1/camel-kafka-connector-0.10.1-src.zip.sha512 Tue Jun 22 16:56:15 2021 @@ -0,0 +1 @@ +a0f7c4a6d634b174e757c0fea25201d902082c6f88615b68d6196185e02b0a466ade3032d16271bd533a6b863cc3ba4c9c1d64c0c1282d2f18532e5475db7f63 \ No newline at end of file
[camel-website] branch main updated: Created release-0.10.1.md (#591)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-website.git The following commit(s) were added to refs/heads/main by this push: new e7b2ed3 Created release-0.10.1.md (#591) e7b2ed3 is described below commit e7b2ed37112165d09ef396e8f993635b38921839 Author: Andrea Tarocchi AuthorDate: Tue Jun 22 22:02:42 2021 +0200 Created release-0.10.1.md (#591) --- content/releases/ckc/release-0.10.1.md | 10 ++ 1 file changed, 10 insertions(+) diff --git a/content/releases/ckc/release-0.10.1.md b/content/releases/ckc/release-0.10.1.md new file mode 100644 index 000..f73373d --- /dev/null +++ b/content/releases/ckc/release-0.10.1.md @@ -0,0 +1,10 @@ +--- +url: "/releases/ckc-0.10.1/" +date: 2021-06-19 +type: release-note +version: "0.10.1" +title: "Camel Kafka Connector release 0.10.1" +preview: "" +changelog: "" +category: "camel-kafka-connector" +---
[camel-website] branch valdar-patch-1 created (now c64f2bf)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git. at c64f2bf Created release-0.10.1.md This branch includes the following new commits: new c64f2bf Created release-0.10.1.md The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-website] 01/01: Created release-0.10.1.md
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git commit c64f2bf1e93c2a17fb5ff34a2fdf88c4d4fc27d1 Author: Andrea Tarocchi AuthorDate: Tue Jun 22 18:58:39 2021 +0200 Created release-0.10.1.md --- content/releases/ckc/release-0.10.1.md | 10 ++ 1 file changed, 10 insertions(+) diff --git a/content/releases/ckc/release-0.10.1.md b/content/releases/ckc/release-0.10.1.md new file mode 100644 index 000..f73373d --- /dev/null +++ b/content/releases/ckc/release-0.10.1.md @@ -0,0 +1,10 @@ +--- +url: "/releases/ckc-0.10.1/" +date: 2021-06-19 +type: release-note +version: "0.10.1" +title: "Camel Kafka Connector release 0.10.1" +preview: "" +changelog: "" +category: "camel-kafka-connector" +---
[camel-kafka-connector] tag camel-kafka-connector-0.10.1 updated (6bb72dd -> 77df912)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.10.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.10.1 was modified! *** from 6bb72dd (tag) to 77df912 (commit) from 785f416 [maven-release-plugin] prepare release camel-kafka-connector-0.10.1 new 77df912 [after release perform chore]: regen catalog descriptors with new version The 1 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-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json| 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-source.json| 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json| 2 +- .../src/generated/resources/connectors/camel-atmos-source.json | 2 +- .../generated/resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-multimap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../generated/resources/connectors/camel-aws-secrets-manager-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-athena-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-cw-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ddb-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ddbstream-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ec2-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ecs-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-eks-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-eventbridge-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../resources/connectors/camel-aws2-kinesis-firehose-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kinesis-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kinesis-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-lambda-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-mq-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-msk-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-s3-si
[camel-kafka-connector] branch main updated: Littel documentation adjustments.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 17c3315 Littel documentation adjustments.
17c3315 is described below
commit 17c3315e59eebf9a57292643d1eb672ca3b840cb
Author: Andrea Tarocchi
AuthorDate: Wed Jun 9 18:02:54 2021 +0200
Littel documentation adjustments.
---
docs/modules/ROOT/nav.adoc | 4 ++--
.../ROOT/pages/{ => user-guide}/camel-compatibility-matrix.adoc | 0
docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc | 6 +++---
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index 1d2300c..6dba34e 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -1,10 +1,10 @@
* xref:user-guide/index.adoc[User guide]
-** xref:user-guide/basic-concepts.adoc[Basic concepts]
** xref:user-guide/index.adoc[Getting started]
*** xref:user-guide/getting-started/try-it-out-locally.adoc[Try it locally]
*** xref:user-guide/getting-started/try-it-out-on-kubernetes.adoc[Try it on
Kubernetes]
***
xref:user-guide/getting-started/try-it-out-on-openshift-with-strimzi.adoc[Try
it on OpenShift cluster]
***
xref:user-guide/getting-started/getting-started-with-packages.adoc[Packages
documentation]
+** xref:user-guide/basic-concepts.adoc[Basic concepts]
** xref:user-guide/basic-configuration.adoc[Basic configuration]
** xref:user-guide/aggregation.adoc[Aggregation]
** xref:user-guide/idempotency.adoc[Idempotency]
@@ -13,11 +13,11 @@
*** xref:user-guide/extending-connector/archetype-connector.adoc[Extensible
connector archetype]
***
xref:user-guide/extending-connector/archetype-dataformat-connector.adoc[Extensible
Dataformat connector archetype]
***
xref:user-guide/extending-connector/archetype-apicurio-connector.adoc[Extensible
Apicurio connector archetype]
+** xref:user-guide/camel-compatibility-matrix.adoc[Apache Camel compatibility
matrix]
* xref:contributor-guide/index.adoc[Contributor guide]
** xref:contributor-guide/testing.adoc[Testing]
** xref:contributor-guide/troubleshooting.adoc[Troubleshooting]
** xref:contributor-guide/release-guide.adoc[Release Guide]
-* xref:camel-compatibility-matrix.adoc[Apache Camel compatibility matrix]
* xref:reference/index.adoc[Reference]
** xref:reference/transformers/index.adoc[Single Message Transformers (SMT)]
*** xref:reference/transformers/fieldsToHeaders.adoc[Fields To Headers]
diff --git a/docs/modules/ROOT/pages/camel-compatibility-matrix.adoc
b/docs/modules/ROOT/pages/user-guide/camel-compatibility-matrix.adoc
similarity index 100%
rename from docs/modules/ROOT/pages/camel-compatibility-matrix.adoc
rename to docs/modules/ROOT/pages/user-guide/camel-compatibility-matrix.adoc
diff --git a/docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc
b/docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc
index b11c773..e13d276 100644
--- a/docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc
+++ b/docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc
@@ -5,6 +5,6 @@ There are scenarios in Camel-Kafka-connector and in the Kafka
Connect world in g
In camel-kafka-connector we provide multiple archetypes for this purpose.
-xref:user-guide/extending-connector/archetype-connector.adoc[Extensible
connector archetype]
-
-
+ * xref:user-guide/extending-connector/archetype-connector.adoc[Extensible
connector archetype]
+ *
xref:user-guide/extending-connector/archetype-dataformat-connector.adoc[Extensible
connector dataformat archetype]
+ *
xref:user-guide/extending-connector/archetype-apicurio-connector.adoc[Extensible
connector apicurio archetype]
[camel-kafka-connector] 03/08: fix #1114 : camel-salesforce-kafka-connector missing dependency library
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.10.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 93185ff4335313f0476acee568f42af6246df008 Author: Andrea Tarocchi AuthorDate: Thu Jun 3 11:16:39 2021 +0200 fix #1114 : camel-salesforce-kafka-connector missing dependency library --- connectors/camel-salesforce-kafka-connector/pom.xml| 7 --- tests/itests-salesforce/pom.xml| 7 --- .../kafkaconnector/salesforce/clients/SalesforceCliContainer.java | 2 +- .../kafkaconnector/salesforce/sink/CamelSinkSalesforceITCase.java | 2 ++ .../salesforce/source/CamelSourceSalesforceITCase.java | 3 +++ 5 files changed, 6 insertions(+), 15 deletions(-) diff --git a/connectors/camel-salesforce-kafka-connector/pom.xml b/connectors/camel-salesforce-kafka-connector/pom.xml index f97614f..35a3585 100644 --- a/connectors/camel-salesforce-kafka-connector/pom.xml +++ b/connectors/camel-salesforce-kafka-connector/pom.xml @@ -43,13 +43,6 @@ org.apache.camel camel-salesforce - - - - org.eclipse.jetty - jetty-http - - diff --git a/tests/itests-salesforce/pom.xml b/tests/itests-salesforce/pom.xml index 81ef830..9517cda 100644 --- a/tests/itests-salesforce/pom.xml +++ b/tests/itests-salesforce/pom.xml @@ -49,13 +49,6 @@ org.apache.camel camel-salesforce - - - -org.eclipse.jetty -jetty-http - - diff --git a/tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SalesforceCliContainer.java b/tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SalesforceCliContainer.java index 4b5a257..8508bee 100644 --- a/tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SalesforceCliContainer.java +++ b/tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SalesforceCliContainer.java @@ -30,7 +30,7 @@ public class SalesforceCliContainer extends GenericContainer
[camel-kafka-connector] branch camel-kafka-connector-0.10.x updated (50997cf -> 0ad2c75)
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch camel-kafka-connector-0.10.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 50997cf Last Released version is 0.10.x
new 9135468 Changed maven test step targets in jenkinsfiles from isntall
to verify.
new 093f5ed Polished jenkins pipeline.
new 93185ff fix #1114 : camel-salesforce-kafka-connector missing
dependency library
new 68bba9f fix #389 : Improve documentation TOC
new a84665b Added Release Documentation.
new cd335ca Some documentation link fixes.
new 1e5fd58 Littel documentation adjustments.
new 0ad2c75 chore: regen.
The 8 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:
Jenkinsfile| 10 +-
Jenkinsfile.jdk11 | 10 +-
.../camel-salesforce-kafka-connector/pom.xml |7 -
docs/modules/ROOT/nav.adoc | 1774 ++--
docs/modules/ROOT/pages/about.adoc |8 -
docs/modules/ROOT/pages/connectors.adoc| 351
.../index.adoc}|2 +-
.../pages/contributor-guide/release-guide.adoc | 201 +++
.../pages/{ => contributor-guide}/testing.adoc |0
.../{ => contributor-guide}/troubleshooting.adoc |0
docs/modules/ROOT/pages/index.adoc | 33 +-
.../camel-activemq-kafka-sink-connector.adoc |0
.../camel-activemq-kafka-source-connector.adoc |0
.../connectors/camel-ahc-kafka-sink-connector.adoc |0
.../camel-ahc-ws-kafka-sink-connector.adoc |0
.../camel-ahc-ws-kafka-source-connector.adoc |0
.../camel-ahc-wss-kafka-sink-connector.adoc|0
.../camel-ahc-wss-kafka-source-connector.adoc |0
.../camel-amqp-kafka-sink-connector.adoc |0
.../camel-amqp-kafka-source-connector.adoc |0
.../camel-apns-kafka-sink-connector.adoc |0
.../camel-apns-kafka-source-connector.adoc |0
.../camel-arangodb-kafka-sink-connector.adoc |0
.../connectors/camel-as2-kafka-sink-connector.adoc |0
.../camel-as2-kafka-source-connector.adoc |0
.../camel-asterisk-kafka-sink-connector.adoc |0
.../camel-asterisk-kafka-source-connector.adoc |0
.../camel-atlasmap-kafka-sink-connector.adoc |0
.../camel-atmos-kafka-sink-connector.adoc |0
.../camel-atmos-kafka-source-connector.adoc|0
...-atmosphere-websocket-kafka-sink-connector.adoc |0
...tmosphere-websocket-kafka-source-connector.adoc |0
.../camel-atom-kafka-source-connector.adoc |0
.../camel-atomix-map-kafka-sink-connector.adoc |0
.../camel-atomix-map-kafka-source-connector.adoc |0
...amel-atomix-messaging-kafka-sink-connector.adoc |0
...el-atomix-messaging-kafka-source-connector.adoc |0
...camel-atomix-multimap-kafka-sink-connector.adoc |0
.../camel-atomix-queue-kafka-sink-connector.adoc |0
.../camel-atomix-queue-kafka-source-connector.adoc |0
.../camel-atomix-set-kafka-sink-connector.adoc |0
.../camel-atomix-set-kafka-source-connector.adoc |0
.../camel-atomix-value-kafka-sink-connector.adoc |0
.../camel-atomix-value-kafka-source-connector.adoc |0
.../camel-avro-kafka-sink-connector.adoc |0
.../camel-avro-kafka-source-connector.adoc |0
.../camel-aws-cw-kafka-sink-connector.adoc |0
.../camel-aws-ddb-kafka-sink-connector.adoc|0
...camel-aws-ddbstream-kafka-source-connector.adoc |0
.../camel-aws-ec2-kafka-sink-connector.adoc|0
.../camel-aws-ecs-kafka-sink-connector.adoc|0
.../camel-aws-eks-kafka-sink-connector.adoc|0
.../camel-aws-iam-kafka-sink-connector.adoc|0
...-aws-kinesis-firehose-kafka-sink-connector.adoc |0
.../camel-aws-kinesis-kafka-sink-connector.adoc|0
.../camel-aws-kinesis-kafka-source-connector.adoc |0
.../camel-aws-kms-kafka-sink-connector.adoc|0
.../camel-aws-lambda-kafka-sink-connector.adoc |0
.../camel-aws-mq-kafka-sink-connector.adoc |0
.../camel-aws-msk-kafka-sink-connector.adoc|0
.../camel-aws-s3-kafka-sink-connector.adoc |0
.../camel-aws-s3-kafka-source-connector.adoc |0
.../camel-aws-sdb-kafka-sink-connector.adoc|0
...l-aws-secrets-manager-kafka-sink-connector.adoc |4 +-
.../camel-aws-ses-kafka-sink-connector.adoc|0
.../camel-aws-sns-kafka-sink-connector.adoc|0
.../camel-aws-sqs-kafka-sink-connector.adoc
[camel-kafka-connector] 01/08: Changed maven test step targets in jenkinsfiles from isntall to verify.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-kafka-connector-0.10.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 91354681d63d3a0ab2785f66d46bf6d59ed1811d
Author: Andrea Tarocchi
AuthorDate: Tue May 25 16:20:00 2021 +0200
Changed maven test step targets in jenkinsfiles from isntall to verify.
---
Jenkinsfile | 2 +-
Jenkinsfile.jdk11 | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/Jenkinsfile b/Jenkinsfile
index bfa1f1d..2caafb6 100644
--- a/Jenkinsfile
+++ b/Jenkinsfile
@@ -66,7 +66,7 @@ pipeline {
stage('Test') {
steps {
-sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true clean install"
+sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true clean verify"
}
post {
always {
diff --git a/Jenkinsfile.jdk11 b/Jenkinsfile.jdk11
index d9312ad..a2e07e7 100644
--- a/Jenkinsfile.jdk11
+++ b/Jenkinsfile.jdk11
@@ -66,7 +66,7 @@ pipeline {
stage('Test') {
steps {
-sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true
-Dfailsafe.rerunFailingTestsCount=2 clean install"
+sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true
-Dfailsafe.rerunFailingTestsCount=2 clean verify"
}
post {
always {
[camel-kafka-connector] 02/08: Polished jenkins pipeline.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-kafka-connector-0.10.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 093f5ed954c1ff4706c823203a7a26abe746aaf4
Author: Andrea Tarocchi
AuthorDate: Wed May 26 07:53:15 2021 +0200
Polished jenkins pipeline.
---
Jenkinsfile | 8 +---
Jenkinsfile.jdk11 | 8 +---
2 files changed, 2 insertions(+), 14 deletions(-)
diff --git a/Jenkinsfile b/Jenkinsfile
index 2caafb6..c5778ee 100644
--- a/Jenkinsfile
+++ b/Jenkinsfile
@@ -58,13 +58,7 @@ pipeline {
}
}
-stage('Build & Deploy') {
-steps {
-sh "./mvnw $MAVEN_PARAMS -Dmaven.test.skip.exec=true clean"
-}
-}
-
-stage('Test') {
+stage('Build & iTest') {
steps {
sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true clean verify"
}
diff --git a/Jenkinsfile.jdk11 b/Jenkinsfile.jdk11
index a2e07e7..ba19738 100644
--- a/Jenkinsfile.jdk11
+++ b/Jenkinsfile.jdk11
@@ -58,13 +58,7 @@ pipeline {
}
}
-stage('Build & Deploy') {
-steps {
-sh "./mvnw $MAVEN_PARAMS -Dmaven.test.skip.exec=true clean
install"
-}
-}
-
-stage('Test') {
+stage('Build & iTest') {
steps {
sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true
-Dfailsafe.rerunFailingTestsCount=2 clean verify"
}
[camel-kafka-connector] 07/08: Littel documentation adjustments.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-kafka-connector-0.10.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 1e5fd58b6c838e92e725ce61b8f7b66a580f6c09
Author: Andrea Tarocchi
AuthorDate: Wed Jun 9 18:02:54 2021 +0200
Littel documentation adjustments.
---
docs/modules/ROOT/nav.adoc | 4 ++--
.../ROOT/pages/{ => user-guide}/camel-compatibility-matrix.adoc | 0
docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc | 6 +++---
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index 1d2300c..6dba34e 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -1,10 +1,10 @@
* xref:user-guide/index.adoc[User guide]
-** xref:user-guide/basic-concepts.adoc[Basic concepts]
** xref:user-guide/index.adoc[Getting started]
*** xref:user-guide/getting-started/try-it-out-locally.adoc[Try it locally]
*** xref:user-guide/getting-started/try-it-out-on-kubernetes.adoc[Try it on
Kubernetes]
***
xref:user-guide/getting-started/try-it-out-on-openshift-with-strimzi.adoc[Try
it on OpenShift cluster]
***
xref:user-guide/getting-started/getting-started-with-packages.adoc[Packages
documentation]
+** xref:user-guide/basic-concepts.adoc[Basic concepts]
** xref:user-guide/basic-configuration.adoc[Basic configuration]
** xref:user-guide/aggregation.adoc[Aggregation]
** xref:user-guide/idempotency.adoc[Idempotency]
@@ -13,11 +13,11 @@
*** xref:user-guide/extending-connector/archetype-connector.adoc[Extensible
connector archetype]
***
xref:user-guide/extending-connector/archetype-dataformat-connector.adoc[Extensible
Dataformat connector archetype]
***
xref:user-guide/extending-connector/archetype-apicurio-connector.adoc[Extensible
Apicurio connector archetype]
+** xref:user-guide/camel-compatibility-matrix.adoc[Apache Camel compatibility
matrix]
* xref:contributor-guide/index.adoc[Contributor guide]
** xref:contributor-guide/testing.adoc[Testing]
** xref:contributor-guide/troubleshooting.adoc[Troubleshooting]
** xref:contributor-guide/release-guide.adoc[Release Guide]
-* xref:camel-compatibility-matrix.adoc[Apache Camel compatibility matrix]
* xref:reference/index.adoc[Reference]
** xref:reference/transformers/index.adoc[Single Message Transformers (SMT)]
*** xref:reference/transformers/fieldsToHeaders.adoc[Fields To Headers]
diff --git a/docs/modules/ROOT/pages/camel-compatibility-matrix.adoc
b/docs/modules/ROOT/pages/user-guide/camel-compatibility-matrix.adoc
similarity index 100%
rename from docs/modules/ROOT/pages/camel-compatibility-matrix.adoc
rename to docs/modules/ROOT/pages/user-guide/camel-compatibility-matrix.adoc
diff --git a/docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc
b/docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc
index b11c773..e13d276 100644
--- a/docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc
+++ b/docs/modules/ROOT/pages/user-guide/extending-connector/index.adoc
@@ -5,6 +5,6 @@ There are scenarios in Camel-Kafka-connector and in the Kafka
Connect world in g
In camel-kafka-connector we provide multiple archetypes for this purpose.
-xref:user-guide/extending-connector/archetype-connector.adoc[Extensible
connector archetype]
-
-
+ * xref:user-guide/extending-connector/archetype-connector.adoc[Extensible
connector archetype]
+ *
xref:user-guide/extending-connector/archetype-dataformat-connector.adoc[Extensible
connector dataformat archetype]
+ *
xref:user-guide/extending-connector/archetype-apicurio-connector.adoc[Extensible
connector apicurio archetype]
[camel-kafka-connector] 05/08: Added Release Documentation.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.10.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit a84665b2ff43078c46a9f481637d881420beb316 Author: Andrea Tarocchi AuthorDate: Mon Jun 7 18:44:56 2021 +0200 Added Release Documentation. --- .../pages/contributor-guide/release-guide.adoc | 201 + 1 file changed, 201 insertions(+) diff --git a/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc b/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc index e69de29..8b550d3 100644 --- a/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc +++ b/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc @@ -0,0 +1,201 @@ +[[ReleaseGuide-ReleaseGuide]] += Apache Camel Kafka Connect release process +:page-aliases: release-guide.adoc + +The process is _mutatis mutandis_ the same as for the main Apache Camel repository - see the +https://camel.apache.org/manual/latest/release-guide.html[Release guide] page of the Camel documentation. + +Here, just a sketch of the repeating part, after you have performed the initial setup following the +https://camel.apache.org/manual/latest/release-guide.html[Camel Release guide]. In particular the section about setting up your maven environment as described in https://camel.apache.org/manual/latest/release-guide.html#ReleaseGuide-MavenSetup[Camel Release Maven Setup]. + +== Pre release tasks + +* Close the GitHub release https://github.com/apache/camel-kafka-connector/milestones[milestone] and assign any remaining issues that aren't covered by the release to the next milestone + +== Create a release branch + +Be sure you switch to a branch to perform the release, do not release from `main` branch unless you have a specific reason and you know what you are doing: + +[source,shell] + +$ git checkout -b + + +IMPORTANT: `` must be different from the `` you will choose later in the release process. + +NOTE: A good branch name is in the form `camel-kafka-connector-0.10.x` if you are performing `0.10.0` release. + +== (Optional) release dry run + +You can do a dry run to be sure all is ok: + +[source,shell] + +$ ./mvnw release:prepare -DdryRun -Prelease -DreleaseVersion= -DdevelopmentVersion= + + +if you performed a dray run please clean up the release before continuing: + +[source,shell] + +$ ./mvnw release:clean + + +== `release:prepare` and `release:perform` + +Prepare the release: + +[source,shell] + +./mvnw -Prelease -DreleaseVersion= -DdevelopmentVersion= -Dtag= -Dusername= -Dpassword= release:prepare + + +NOTE: `` is usual in the form of `camel-kafka-connector-` + +Add and commit all the updated json with a commit comment on the line of `"[after release perform chore]: regen catalog descriptors with new version"` then update the tag `` to point to the just created commit and push it upstream (you may need to delate the original tag `` created during the `release:prepare` step above): + +[source,shell] + +$ git add *.json +$ git stash +$ git checkout +$ git stash pop +$ git add *.json +$ git commit -m"[after release perform chore]: regen catalog descriptors with new version" +$ git tag -f +$ git push -f upstream +$ git checkout + + +Upload your artifacts on apache nexus maven server: + +[source,shell] + +$ ./mvnw -Prelease -Dusername= -Dpassword= release:perform + + +[source,shell] + +$ mvn clean release:clean release:prepare -DreleaseVersion=$VERSION -DdevelopmentVersion=$NEXT_VERSION -B release:perform + + +In case an issue occurs during `release:perform`, it could be worth trying to resume from the failing artifact. +For instance, would an issue occurs while performing the release of `camel-splunk-kafka-connector`, a resume attempt could be triggered as below: + +[source,shell] + +$ cd target/checkout +$ ./mvnw -Prelease -Dusername= -Dpassword= deploy -rf :camel-splunk-kafka-connector + + +== Close Apache Nexus staging repository + + * Go to https://repository.apache.org + * staging repository + * select the open repository (the name usually contains a number) + * close it + +There will be some checks done by nexus, wiat tho see that they complete successfully. + +== Open the vote + +Send an email to d...@camel.apache.org with object: `[VOTE] Release Camel-Kafka-connector ` you can select 48 or 72 hours for the vote. The message can be something like: + +[source,text] + +Hello all, + +This is a vote to release Apache Camel-kafka-connector X + +Staging repository: +https://repository.apache.org/content/repositories/orgapachecamel-Y + +Tag: +https://gitbox.apache.org/repos/asf?p=camel-kafka-connector.git;a=tag;h=refs/tags/camel-kafka-connector-X + + + +Please test this release candidate and cast your vote. +[ ] +1 Release the binary as Apache Camel-kafka-connector X +[ ] -1 Veto
[camel-kafka-connector] 08/08: chore: regen.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-kafka-connector-0.10.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 0ad2c756b4771a016e8dd95558949dd009ca1f05
Author: Andrea Tarocchi
AuthorDate: Thu Jun 10 00:17:07 2021 +0200
chore: regen.
---
.../src/generated/resources/camel-kafka-sink.json | 14 --
.../src/main/docs/camel-kafka-kafka-sink-connector.adoc| 4 +---
.../kafka/CamelKafkaSinkConnectorConfig.java | 8
3 files changed, 1 insertion(+), 25 deletions(-)
diff --git
a/connectors/camel-kafka-kafka-connector/src/generated/resources/camel-kafka-sink.json
b/connectors/camel-kafka-kafka-connector/src/generated/resources/camel-kafka-sink.json
index 954a5df..3173565 100644
---
a/connectors/camel-kafka-kafka-connector/src/generated/resources/camel-kafka-sink.json
+++
b/connectors/camel-kafka-kafka-connector/src/generated/resources/camel-kafka-sink.json
@@ -80,13 +80,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.deliveryTimeoutMs": {
- "name": "camel.sink.endpoint.deliveryTimeoutMs",
- "description": "An upper bound on the time to report
success or failure after a call to send() returns. This limits the total time
that a record will be delayed prior to sending, the time to await
acknowledgement from the broker (if expected), and the time allowed for
retriable send failures.",
- "defaultValue": "\"12\"",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.enableIdempotence": {
"name": "camel.sink.endpoint.enableIdempotence",
"description": "If set to 'true' the producer will
ensure that exactly one copy of each message is written in the stream. If
'false', producer retries may write duplicates of the retried message in the
stream. If set to true this option will require
max.in.flight.requests.per.connection to be set to 1 and retries cannot be zero
and additionally acks must be set to 'all'.",
@@ -537,13 +530,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.kafka.deliveryTimeoutMs": {
- "name": "camel.component.kafka.deliveryTimeoutMs",
- "description": "An upper bound on the time to report
success or failure after a call to send() returns. This limits the total time
that a record will be delayed prior to sending, the time to await
acknowledgement from the broker (if expected), and the time allowed for
retriable send failures.",
- "defaultValue": "\"12\"",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.kafka.enableIdempotence": {
"name": "camel.component.kafka.enableIdempotence",
"description": "If set to 'true' the producer will
ensure that exactly one copy of each message is written in the stream. If
'false', producer retries may write duplicates of the retried message in the
stream. If set to true this option will require
max.in.flight.requests.per.connection to be set to 1 and retries cannot be zero
and additionally acks must be set to 'all'.",
diff --git
a/connectors/camel-kafka-kafka-connector/src/main/docs/camel-kafka-kafka-sink-connector.adoc
b/connectors/camel-kafka-kafka-connector/src/main/docs/camel-kafka-kafka-sink-connector.adoc
index 90a7a69..3e2b65e 100644
---
a/connectors/camel-kafka-kafka-connector/src/main/docs/camel-kafka-kafka-sink-connector.adoc
+++
b/connectors/camel-kafka-kafka-connector/src/main/docs/camel-kafka-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.kafka.CamelKafkaSinkConnector
-The camel-kafka sink connector supports 137 options, which are listed below.
+The camel-kafka sink connector supports 135 options, which are listed below.
@@ -41,7 +41,6 @@ The camel-kafka sink connector supports 137 options, which
are listed below.
| *camel.sink.endpoint.bufferMemorySize* | The total bytes of memory the
producer can use to buffer records waiting to be sent to the server. If records
are sent faster than they c
[camel-website] branch valdar-patch-1 updated (5f36a6e -> cce16a1)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git. from 5f36a6e Added redirect for camel-kafka-connector connector list page. add cce16a1 Update static/.htaccess No new revisions were added by this update. Summary of changes: static/.htaccess | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel-kafka-connector] branch main updated (abb297f -> e95a63b)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from abb297f [create-pull-request] automated change new 7c572b7 Fixed syslog documentation xref: links. new e95a63b Fixed internal doc links. The 2 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/main/docs/camel-syslog-kafka-sink-connector.adoc | 2 +- .../src/main/docs/camel-syslog-kafka-source-connector.adoc| 2 +- docs/modules/ROOT/pages/contributor-guide/release-guide.adoc | 4 ++-- .../pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc | 2 +- .../reference/connectors/camel-syslog-kafka-source-connector.adoc | 2 +- 5 files changed, 6 insertions(+), 6 deletions(-)
[camel-kafka-connector] 01/02: Fixed syslog documentation xref: links.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 7c572b74a367b5534907e3d9480b39f635ac69b1 Author: Andrea Tarocchi AuthorDate: Thu Jun 10 01:22:55 2021 +0200 Fixed syslog documentation xref: links. --- .../src/main/docs/camel-syslog-kafka-sink-connector.adoc| 2 +- .../src/main/docs/camel-syslog-kafka-source-connector.adoc | 2 +- .../pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc | 2 +- .../pages/reference/connectors/camel-syslog-kafka-source-connector.adoc | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc b/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc index 1d3eda4..53a23e0 100644 --- a/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc +++ b/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc @@ -15,7 +15,7 @@ When using camel-syslog-kafka-connector as sink make sure to use the following M -The camel-syslog sink connector supports is based on camel-netty sink connector and supports all its options (see: xref:connectors/camel-netty-kafka-sink-connector.adoc[Netty Sink Docs]); +The camel-syslog sink connector supports is based on camel-netty sink connector and supports all its options (see: xref:reference/connectors/camel-netty-kafka-sink-connector.adoc[Netty Sink Docs]); however has been already preconfigured and should be sufficient to provide the following properties: [width="100%",cols="2,5,^1,2",options="header"] |=== diff --git a/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc b/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc index 92152ff..b55a916 100644 --- a/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc +++ b/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc @@ -15,7 +15,7 @@ When using camel-syslog-kafka-connector as source make sure to use the following -The camel-syslog source connector supports is based on camel-netty source connector and supports all its options (see: xref:connectors/camel-netty-kafka-source-connector.adoc[Netty Source Docs]); +The camel-syslog source connector supports is based on camel-netty source connector and supports all its options (see: xref:reference/connectors/camel-netty-kafka-source-connector.adoc[Netty Source Docs]); however has been already preconfigured and should be sufficient to provide the following properties: [width="100%",cols="2,5,^1,2",options="header"] |=== diff --git a/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc index 1d3eda4..53a23e0 100644 --- a/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc +++ b/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc @@ -15,7 +15,7 @@ When using camel-syslog-kafka-connector as sink make sure to use the following M -The camel-syslog sink connector supports is based on camel-netty sink connector and supports all its options (see: xref:connectors/camel-netty-kafka-sink-connector.adoc[Netty Sink Docs]); +The camel-syslog sink connector supports is based on camel-netty sink connector and supports all its options (see: xref:reference/connectors/camel-netty-kafka-sink-connector.adoc[Netty Sink Docs]); however has been already preconfigured and should be sufficient to provide the following properties: [width="100%",cols="2,5,^1,2",options="header"] |=== diff --git a/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-source-connector.adoc b/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-source-connector.adoc index 92152ff..b55a916 100644 --- a/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-source-connector.adoc +++ b/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-source-connector.adoc @@ -15,7 +15,7 @@ When using camel-syslog-kafka-connector as source make sure to use the following -The camel-syslog source connector supports is based on camel-netty source connector and supports all its options (see: xref:connectors/camel-netty-kafka-source-connector.adoc[Netty Source Docs]); +The camel-syslog source connector supports is based on camel-netty source connector and supports all its options (see: xref:reference/connectors/camel-netty-kafka-source-connector.adoc[Netty S
[camel-kafka-connector] 02/02: Fixed internal doc links.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit e95a63b97518b3eaa11cd67c543f57535aab4c92 Author: Andrea Tarocchi AuthorDate: Thu Jun 10 21:22:11 2021 +0200 Fixed internal doc links. --- docs/modules/ROOT/pages/contributor-guide/release-guide.adoc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc b/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc index 8b550d3..2b07d69 100644 --- a/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc +++ b/docs/modules/ROOT/pages/contributor-guide/release-guide.adoc @@ -3,10 +3,10 @@ :page-aliases: release-guide.adoc The process is _mutatis mutandis_ the same as for the main Apache Camel repository - see the -https://camel.apache.org/manual/latest/release-guide.html[Release guide] page of the Camel documentation. +xref:latest@manual::release-guide.adoc[Release guide] page of the Camel documentation. Here, just a sketch of the repeating part, after you have performed the initial setup following the -https://camel.apache.org/manual/latest/release-guide.html[Camel Release guide]. In particular the section about setting up your maven environment as described in https://camel.apache.org/manual/latest/release-guide.html#ReleaseGuide-MavenSetup[Camel Release Maven Setup]. +xref:latest@manual::release-guide.adoc[Camel Release guide]. In particular the section about setting up your maven environment as described in xref:latest@manual::release-guide.adoc#ReleaseGuide-MavenSetup[Camel Release Maven Setup]. == Pre release tasks
[camel-website] branch valdar-patch-1 created (now 5f36a6e)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git. at 5f36a6e Added redirect for camel-kafka-connector connector list page. This branch includes the following new commits: new 5f36a6e Added redirect for camel-kafka-connector connector list page. The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-website] 01/01: Added redirect for camel-kafka-connector connector list page.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git commit 5f36a6ec836b91bb90c1b4db3c3ede10383ea80a Author: Andrea Tarocchi AuthorDate: Fri Jun 11 12:58:51 2021 +0200 Added redirect for camel-kafka-connector connector list page. --- static/.htaccess | 3 +++ 1 file changed, 3 insertions(+) diff --git a/static/.htaccess b/static/.htaccess index 8f95452..016b3af 100644 --- a/static/.htaccess +++ b/static/.htaccess @@ -729,6 +729,9 @@ Redirect 301 /camel-quarkus/latest/extensions/xstream.html /camel-quarkus/latest Redirect 301 /camel-quarkus/latest/extensions/zip-deflater.html /camel-quarkus/latest/reference/extensions/zip-deflater.html Redirect 301 /camel-quarkus/latest/extensions/zipfile.html /camel-quarkus/latest/reference/extensions/zipfile.html # camel-quarkus end +# camel-kafka-connect start +Redirect 301 camel-kafka-connector/latest/connectors.html /camel-kafka-connector/latest/reference/index.html +# camel-kafka-connect end Redirect 301 /camel-run-maven-goal.html /manual/latest/camel-run-maven-goal.html Redirect 301 /camel-test /components/latest/test.html Redirect 301 /camel-test.html /components/latest/test.html
[camel-kafka-connector] branch camel-kafka-connector-0.10.x updated: Fixed syslog documentation xref: links.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.10.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-0.10.x by this push: new 0c52e65 Fixed syslog documentation xref: links. 0c52e65 is described below commit 0c52e6530f0aea5af0d0022d61e84184b563e73e Author: Andrea Tarocchi AuthorDate: Thu Jun 10 01:22:55 2021 +0200 Fixed syslog documentation xref: links. --- .../src/main/docs/camel-syslog-kafka-sink-connector.adoc| 2 +- .../src/main/docs/camel-syslog-kafka-source-connector.adoc | 2 +- .../pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc | 2 +- .../pages/reference/connectors/camel-syslog-kafka-source-connector.adoc | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc b/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc index 1d3eda4..53a23e0 100644 --- a/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc +++ b/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-sink-connector.adoc @@ -15,7 +15,7 @@ When using camel-syslog-kafka-connector as sink make sure to use the following M -The camel-syslog sink connector supports is based on camel-netty sink connector and supports all its options (see: xref:connectors/camel-netty-kafka-sink-connector.adoc[Netty Sink Docs]); +The camel-syslog sink connector supports is based on camel-netty sink connector and supports all its options (see: xref:reference/connectors/camel-netty-kafka-sink-connector.adoc[Netty Sink Docs]); however has been already preconfigured and should be sufficient to provide the following properties: [width="100%",cols="2,5,^1,2",options="header"] |=== diff --git a/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc b/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc index 92152ff..b55a916 100644 --- a/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc +++ b/connectors/camel-syslog-kafka-connector/src/main/docs/camel-syslog-kafka-source-connector.adoc @@ -15,7 +15,7 @@ When using camel-syslog-kafka-connector as source make sure to use the following -The camel-syslog source connector supports is based on camel-netty source connector and supports all its options (see: xref:connectors/camel-netty-kafka-source-connector.adoc[Netty Source Docs]); +The camel-syslog source connector supports is based on camel-netty source connector and supports all its options (see: xref:reference/connectors/camel-netty-kafka-source-connector.adoc[Netty Source Docs]); however has been already preconfigured and should be sufficient to provide the following properties: [width="100%",cols="2,5,^1,2",options="header"] |=== diff --git a/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc index 1d3eda4..53a23e0 100644 --- a/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc +++ b/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-sink-connector.adoc @@ -15,7 +15,7 @@ When using camel-syslog-kafka-connector as sink make sure to use the following M -The camel-syslog sink connector supports is based on camel-netty sink connector and supports all its options (see: xref:connectors/camel-netty-kafka-sink-connector.adoc[Netty Sink Docs]); +The camel-syslog sink connector supports is based on camel-netty sink connector and supports all its options (see: xref:reference/connectors/camel-netty-kafka-sink-connector.adoc[Netty Sink Docs]); however has been already preconfigured and should be sufficient to provide the following properties: [width="100%",cols="2,5,^1,2",options="header"] |=== diff --git a/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-source-connector.adoc b/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-source-connector.adoc index 92152ff..b55a916 100644 --- a/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-source-connector.adoc +++ b/docs/modules/ROOT/pages/reference/connectors/camel-syslog-kafka-source-connector.adoc @@ -15,7 +15,7 @@ When using camel-syslog-kafka-connector as source make sure to use the following -The camel-syslog source connector supports is based on camel-netty source connector and supports all its options (see: xref:connectors/camel-netty-kafka-source-connector.adoc[Netty Source Doc
[camel-kafka-connector] branch main updated: Fix AWS2 Cloud Watch test issues due to LocalStack bug
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new b4e43b3 Fix AWS2 Cloud Watch test issues due to LocalStack bug
b4e43b3 is described below
commit b4e43b3a64ac3fe2b8b1052e30fbd918a960613e
Author: Otavio Rodolfo Piske
AuthorDate: Fri May 14 15:54:55 2021 +0200
Fix AWS2 Cloud Watch test issues due to LocalStack bug
Dimensions are not working correctly in LocalStack's implementation of
cloud watch in LocalStack 0.12.10. This forces the test to use 0.12.9.1
---
.../aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 18 +-
1 file changed, 17 insertions(+), 1 deletion(-)
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
index 550ea47..f6447da 100644
---
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
@@ -30,7 +30,10 @@ import
org.apache.camel.kafkaconnector.common.test.StringMessageProducer;
import org.apache.camel.kafkaconnector.common.utils.TestUtils;
import org.apache.camel.test.infra.aws.common.services.AWSService;
import org.apache.camel.test.infra.aws2.clients.AWSSDKClientUtils;
+import org.apache.camel.test.infra.aws2.services.AWSLocalContainerService;
+import org.apache.camel.test.infra.aws2.services.AWSRemoteService;
import org.apache.camel.test.infra.aws2.services.AWSServiceFactory;
+import org.apache.camel.test.infra.aws2.services.Service;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInstance;
@@ -53,7 +56,13 @@ import static org.junit.jupiter.api.Assertions.fail;
public class CamelSinkAWSCWITCase extends CamelSinkTestSupport {
@RegisterExtension
-public static AWSService awsService =
AWSServiceFactory.createCloudWatchService();
+public static AWSService awsService = AWSServiceFactory
+.builder()
+.addRemoteMapping(AWSRemoteService::new)
+.addLocalMapping(CustomAWSCloudWatchLocalContainerService::new)
+.withPropertyNameFormat("%s-service.instance.type")
+.build();
+
private static final Logger LOG =
LoggerFactory.getLogger(CamelSinkAWSCWITCase.class);
private CloudWatchClient client;
@@ -63,6 +72,13 @@ public class CamelSinkAWSCWITCase extends
CamelSinkTestSupport {
private volatile int received;
private final int expect = 10;
+// Dimensions are broken in localstack implementation of CloudWatch 0.12.10
+private static class CustomAWSCloudWatchLocalContainerService extends
AWSLocalContainerService {
+public CustomAWSCloudWatchLocalContainerService() {
+super("localstack/localstack:0.12.9.1", Service.CLOUD_WATCH);
+}
+}
+
private static class CustomProducer extends StringMessageProducer {
public CustomProducer(String bootstrapServer, String topicName, int
count) {
super(bootstrapServer, topicName, count);
[camel-kafka-connector] 02/02: Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551 for sinks
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch kamelets
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 893bd7a94839ad1a9740c438bc8cb2f23c146e21
Author: Andrea Tarocchi
AuthorDate: Wed May 19 10:46:13 2021 +0200
Related to #423 resolved a problem with marshal/unmarshal after fixin
https://issues.apache.org/jira/browse/CAMEL-16551 for sinks
---
.../utils/CamelKafkaConnectMain.java | 25 +++---
1 file changed, 12 insertions(+), 13 deletions(-)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index 036375b..0871307 100644
---
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
+++
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
@@ -230,12 +230,12 @@ public class CamelKafkaConnectMain extends SimpleMain {
//dataformats
if (!ObjectHelper.isEmpty(marshallDataFormat)) {
-
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
-
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
+
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"marshal", marshallDataFormat);
+
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"marshal", marshallDataFormat);
}
if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
-
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
-
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
+
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"unmarshal", unmarshallDataFormat);
+
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"unmarshal", unmarshallDataFormat);
}
//aggregator
@@ -310,8 +310,8 @@ public class CamelKafkaConnectMain extends SimpleMain {
.templateParameter("fromUrl")
.templateParameter("errorHandler",
"ckcErrorHandler")
-.templateParameter("marshall", "dummyDataformat")
-.templateParameter("unmarshall", "dummyDataformat")
+.templateParameter("marshal", "dummyDataformat")
+.templateParameter("unmarshal", "dummyDataformat")
//TODO: change
CamelConnectorConfig.CAMEL_CONNECTOR_AGGREGATE_NA to ckcAggregationStrategy?
.templateParameter("aggregationStrategy",
CamelConnectorConfig.CAMEL_CONNECTOR_AGGREGATE_NAME)
@@ -326,10 +326,10 @@ public class CamelKafkaConnectMain extends SimpleMain {
ProcessorDefinition rdInTemplateSource =
rtdSource.from("{{fromUrl}}")
.errorHandler(new
ErrorHandlerBuilderRef("{{errorHandler}}"));
if (!ObjectHelper.isEmpty(marshallDataFormat)) {
-rdInTemplateSource =
rdInTemplateSource.marshal("{{marshall}}");
+rdInTemplateSource =
rdInTemplateSource.marshal("{{marshal}}");
}
if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
-rdInTemplateSource =
rdInTemplateSource.unmarshal("{{unmarshall}}");
+rdInTemplateSource =
rdInTemplateSource.unmarshal("{{unmarshal}}");
}
if (getContext().getRegistry().lookupByName("aggregate")
!= null) {
@@ -351,9 +351,8 @@ public class CamelKafkaConnectMain extends SimpleMain {
RouteTemplateDefinition rtdSink = routeTemplate("ckcSink")
.templateParameter("toUrl")
.templateParameter("errorHandler",
"ckcErrorHandler")
-//TODO: enable or delete these parameters once
https://issues.apache.org/jira/browse/CAMEL-16551 is resolved
-//.templateParameter("marshall", "dummyDataformat")
-//.templateParameter("unmarshall",
"dummyDataformat")
[camel-kafka-connector] branch kamelets updated (9b229ed -> 893bd7a)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch kamelets in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. discard 9b229ed Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551 new 01def30 Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551 for sources new 893bd7a Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551 for sinks 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 (9b229ed) \ N -- N -- N refs/heads/kamelets (893bd7a) 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 2 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: .../utils/CamelKafkaConnectMain.java | 25 +++--- 1 file changed, 12 insertions(+), 13 deletions(-)
[camel-kafka-connector] 01/02: Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551 for sources
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch kamelets
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 01def3089c3173ed4d5fd96be12db4874842e982
Author: Andrea Tarocchi
AuthorDate: Sat May 15 07:59:12 2021 +0200
Related to #423 resolved a problem with marshal/unmarshal after fixin
https://issues.apache.org/jira/browse/CAMEL-16551 for sources
---
.../utils/CamelKafkaConnectMain.java | 29 +++---
.../camel/kafkaconnector/CamelSourceTaskTest.java | 5
2 files changed, 14 insertions(+), 20 deletions(-)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index 6e7dbdf..036375b 100644
---
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
+++
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
@@ -228,16 +228,15 @@ public class CamelKafkaConnectMain extends SimpleMain {
Properties camelProperties = new Properties();
camelProperties.putAll(props);
-//TODO: enable or delete these parameters once
https://issues.apache.org/jira/browse/CAMEL-16551 is resolved
-////dataformats
-//if (!ObjectHelper.isEmpty(marshallDataFormat)) {
-//
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLETE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
-//
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
-//}
-//if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
-//
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLETE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
-//
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
-//}
+//dataformats
+if (!ObjectHelper.isEmpty(marshallDataFormat)) {
+
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
+
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
+}
+if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
+
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
+
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
+}
//aggregator
if (!ObjectHelper.isEmpty(aggregationSize)) {
@@ -310,9 +309,9 @@ public class CamelKafkaConnectMain extends SimpleMain {
RouteTemplateDefinition rtdSource =
routeTemplate("ckcSource")
.templateParameter("fromUrl")
.templateParameter("errorHandler",
"ckcErrorHandler")
-//TODO: enable or delete these parameters once
https://issues.apache.org/jira/browse/CAMEL-16551 is resolved
-//.templateParameter("marshall", "dummyDataformat")
-//.templateParameter("unmarshall",
"dummyDataformat")
+
+.templateParameter("marshall", "dummyDataformat")
+.templateParameter("unmarshall", "dummyDataformat")
//TODO: change
CamelConnectorConfig.CAMEL_CONNECTOR_AGGREGATE_NA to ckcAggregationStrategy?
.templateParameter("aggregationStrategy",
CamelConnectorConfig.CAMEL_CONNECTOR_AGGREGATE_NAME)
@@ -327,10 +326,10 @@ public class CamelKafkaConnectMain extends SimpleMain {
ProcessorDefinition rdInTemplateSource =
rtdSource.from("{{fromUrl}}")
.errorHandler(new
ErrorHandlerBuilderRef("{{errorHandler}}"));
if (!ObjectHelper.isEmpty(marshallDataFormat)) {
-rdInTemplateSource =
rdInTemplateSource.marshal(marshallDataFormat);
+rdInTemplateSource =
rdInTemplateSource.marshal("{{marshall}}");
}
if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
-rdInTemplateSource =
rdInTemplateSource.unmarshal(unmarshallDataFormat);
+rdInTemplateSource =
rdInTemplateSource.unmarshal("{{unmarshall}}");
}
i
[camel-kafka-connector] branch main updated: Fixed Kinesis shards failing tests.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 407ee92 Fixed Kinesis shards failing tests.
407ee92 is described below
commit 407ee920a5febae2d74d5947c8122be5ea774488
Author: Andrea Tarocchi
AuthorDate: Sat May 15 08:48:18 2021 +0200
Fixed Kinesis shards failing tests.
---
.../apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
index fb1d64a..de2e59c 100644
---
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
@@ -195,7 +195,7 @@ public final class KinesisUtils {
private static boolean hasShards(KinesisClient kinesisClient,
DescribeStreamRequest describeStreamRequest) {
DescribeStreamResponse streamRes =
kinesisClient.describeStream(describeStreamRequest);
-return streamRes.streamDescription().shards().isEmpty();
+return !streamRes.streamDescription().shards().isEmpty();
}
private static List getAllShards(KinesisClient kinesisClient,
DescribeStreamRequest describeStreamRequest) {
[camel-kafka-connector] branch main updated: [create-pull-request] automated change
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 34c3b41 [create-pull-request] automated change
34c3b41 is described below
commit 34c3b418b5f993300b86cecefed84bf491ee1f48
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat May 15 03:56:28 2021 +
[create-pull-request] automated change
---
.../resources/connectors/camel-aws2-cw-sink.json | 4 ++--
.../resources/connectors/camel-aws2-kms-sink.json | 14 ++
.../resources/connectors/camel-aws2-lambda-sink.json | 18 --
.../resources/connectors/camel-mongodb-sink.json | 18 ++
.../resources/connectors/camel-mongodb-source.json | 18 ++
.../src/generated/resources/camel-aws2-cw-sink.json| 4 ++--
.../main/docs/camel-aws2-cw-kafka-sink-connector.adoc | 4 ++--
.../aws2cw/CamelAws2cwSinkConnectorConfig.java | 4 ++--
.../src/generated/resources/camel-aws2-kms-sink.json | 14 ++
.../main/docs/camel-aws2-kms-kafka-sink-connector.adoc | 4 +++-
.../aws2kms/CamelAws2kmsSinkConnectorConfig.java | 8
.../generated/resources/camel-aws2-lambda-sink.json| 18 --
.../docs/camel-aws2-lambda-kafka-sink-connector.adoc | 8 +---
.../aws2lambda/CamelAws2lambdaSinkConnectorConfig.java | 12 ++--
.../src/generated/resources/camel-mongodb-sink.json| 18 ++
.../src/generated/resources/camel-mongodb-source.json | 18 ++
.../main/docs/camel-mongodb-kafka-sink-connector.adoc | 5 -
.../docs/camel-mongodb-kafka-source-connector.adoc | 5 -
.../mongodb/CamelMongodbSinkConnectorConfig.java | 12
.../mongodb/CamelMongodbSourceConnectorConfig.java | 12
.../connectors/camel-aws2-cw-kafka-sink-connector.adoc | 4 ++--
.../camel-aws2-kms-kafka-sink-connector.adoc | 4 +++-
.../camel-aws2-lambda-kafka-sink-connector.adoc| 8 +---
.../connectors/camel-mongodb-kafka-sink-connector.adoc | 5 -
.../camel-mongodb-kafka-source-connector.adoc | 5 -
25 files changed, 216 insertions(+), 28 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
index 8a94f96..841807d 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
@@ -66,7 +66,7 @@
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
- "description": "The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which CW client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
@@ -177,7 +177,7 @@
},
"camel.component.aws2-cw.region": {
"name": "camel.component.aws2-cw.region",
- "description": "The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which CW client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kms-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kms-sink.json
index 2fa387e..b689bfa 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kms-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/conn
[camel-kafka-connector] branch main updated: Made Kinesis tests hopefully more robust.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new b38f9a1 Made Kinesis tests hopefully more robust.
b38f9a1 is described below
commit b38f9a13f6031838bda8d952683b47af4b6f3ff4
Author: Andrea Tarocchi
AuthorDate: Sun May 16 00:02:36 2021 +0200
Made Kinesis tests hopefully more robust.
---
.../aws/v2/kinesis/common/KinesisUtils.java| 32 +-
.../pubsub/sink/CamelSinkGooglePubSubITCase.java | 2 +-
2 files changed, 26 insertions(+), 8 deletions(-)
diff --git
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
index de2e59c..2f86837 100644
---
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
+++
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
@@ -34,12 +34,14 @@ import
software.amazon.awssdk.services.kinesis.model.DeleteStreamResponse;
import software.amazon.awssdk.services.kinesis.model.DescribeStreamRequest;
import software.amazon.awssdk.services.kinesis.model.DescribeStreamResponse;
import software.amazon.awssdk.services.kinesis.model.GetRecordsRequest;
+import software.amazon.awssdk.services.kinesis.model.GetRecordsResponse;
import software.amazon.awssdk.services.kinesis.model.GetShardIteratorRequest;
import software.amazon.awssdk.services.kinesis.model.GetShardIteratorResponse;
import software.amazon.awssdk.services.kinesis.model.KinesisException;
import software.amazon.awssdk.services.kinesis.model.PutRecordsRequest;
import software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry;
import software.amazon.awssdk.services.kinesis.model.PutRecordsResponse;
+import software.amazon.awssdk.services.kinesis.model.Record;
import software.amazon.awssdk.services.kinesis.model.ResourceInUseException;
import software.amazon.awssdk.services.kinesis.model.ResourceNotFoundException;
import software.amazon.awssdk.services.kinesis.model.Shard;
@@ -76,13 +78,7 @@ public final class KinesisUtils {
public static void createStream(KinesisClient kinesisClient, String
streamName) {
try {
LOG.info("Checking whether the stream exists already");
-DescribeStreamRequest request = DescribeStreamRequest.builder()
-.streamName(streamName)
-.build();
-
-DescribeStreamResponse response =
kinesisClient.describeStream(request);
-
-int status = response.sdkHttpResponse().statusCode();
+int status = getStreamStatus(kinesisClient, streamName);
LOG.info("Kinesis stream check result: {}", status);
} catch (KinesisException e) {
if (LOG.isTraceEnabled()) {
@@ -92,9 +88,31 @@ public final class KinesisUtils {
}
doCreateStream(kinesisClient, streamName);
+TestUtils.waitFor(() -> {
+try {
+GetRecordsRequest getRecordsRequest =
KinesisUtils.getGetRecordsRequest(kinesisClient, streamName);
+GetRecordsResponse response =
kinesisClient.getRecords(getRecordsRequest);
+List recordList = response.records();
+LOG.debug("Checking for stream creation by reading {}
records: SUCCESS!", recordList.size());
+return true;
+} catch (Exception exc) {
+LOG.debug("Checking for stream creation by reading
records: FAILURE, retrying..");
+return false;
+}
+});
}
}
+private static int getStreamStatus(KinesisClient kinesisClient, String
streamName) {
+DescribeStreamRequest request = DescribeStreamRequest.builder()
+.streamName(streamName)
+.build();
+
+DescribeStreamResponse response =
kinesisClient.describeStream(request);
+
+return response.sdkHttpResponse().statusCode();
+}
+
public static void doDeleteStream(KinesisClient kinesisClient, String
streamName) {
DeleteStreamRequest request = DeleteStreamRequest.builder()
.streamName(streamName)
diff --git
a/tests/itests-google-pubsub/src/test/java/org/apache/camel/kafkaconnector/google/pubsub/sink/CamelSinkGooglePubSubITCase.java
b/tests/itests-google-pubsub/src/test/java/org/apache/camel/kafkaconnector/google/pubsub/sink/CamelSinkGooglePubSubITCase.java
index af99586..dc56875 100644
---
a/tests/itests-google-pubsub/src/test/java/org/apache/camel/kafkaconnector/google/pubsub/sink/CamelSinkGooglePubSubITCase.java
+++
b/t
[camel-kafka-connector] branch kamelets updated (5df87a0 -> e0a4d6a)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch kamelets in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. discard 5df87a0 chore: regen. discard ae61051 Related to #423 : caonverted source and sink to use camel-kamelets. add 84d851b Return ealier from SJMS test to avoid locking the test add edabc81 Removes outdated AWS v1 log configuration add 9f837cc Updated CHANGELOG.md add dbbaa30 [create-pull-request] automated change add d985fc7 Add autoCreateTopic to fix AWS v2 SNS tests add d51b0c4 Avoid using a fixed port for the REST service of Kafka Connect add 0ed1021 Fixed AWS test errors w/ Strimzi due to incorrect test lifecycle add bf14b67 Updated CHANGELOG.md add 860157b Added a configuration for controlling queue auto-creation add 6176d3b Documented the reason why some AWS SQS source tests are disabled add c1c8ee7 Updated CHANGELOG.md add 2c668e0 [create-pull-request] automated change add a47ec7d Updated CHANGELOG.md add bfb56c5 Updated CHANGELOG.md add 6e71875 [create-pull-request] automated change add 892cbe0 Updated CHANGELOG.md add cc3fdc7 Updated CHANGELOG.md add 276790e [create-pull-request] automated change add dbe3ef3 Updated CHANGELOG.md add 2b73089 [create-pull-request] automated change add 531b120 Updated CHANGELOG.md add 5dadfed Updated CHANGELOG.md add 9e53842 [create-pull-request] automated change add e8009d7 Updated CHANGELOG.md add ad803b4 Updated CHANGELOG.md add 612dfc3 [create-pull-request] automated change add 6f40452 Updated CHANGELOG.md add d0a3b39 Updated CHANGELOG.md add 08e0cd6 [create-pull-request] automated change add 38eecd5 Upgrade to Kafka 2.8.0 add 5b734bc Upgrade Strimzi to version 0.23.0-rc1-kafka-2.8.0 add b384601 Updated CHANGELOG.md add b8e1614 Moving Changelog action to version 1.4 add 86e675f Updated CHANGELOG.md add c343c11 [create-pull-request] automated change add 7b919aa Upgrade to Strimzi 0.23.0 add 0f8d4e9 Fix AWS2 Kinesis Sink issues add b4e43b3 Fix AWS2 Cloud Watch test issues due to LocalStack bug add 8431292 Updated CHANGELOG.md add 34c3b41 [create-pull-request] automated change add 407ee92 Fixed Kinesis shards failing tests. add 9e63968 Updated CHANGELOG.md add 87ca504 [create-pull-request] automated change add b38f9a1 Made Kinesis tests hopefully more robust. new e3ee40f Related to #423 : caonverted source and sink to use camel-kamelets. new e0a4d6a Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551 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 (5df87a0) \ N -- N -- N refs/heads/kamelets (e0a4d6a) 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 2 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: .github/actions/changelog | 2 +- CHANGELOG.md | 643 +++-- .../connectors/camel-activemq-source.json | 6 + .../resources/connectors/camel-atlasmap-sink.json | 12 +- .../connectors/camel-aws2-athena-sink.json | 14 + .../resources/connectors/camel-aws2-cw-sink.json | 18 +- .../resources/connectors/camel-aws2-ddb-sink.json | 14 + .../connectors/camel-aws2-ddbstream-source.json| 14 + .../resources/connectors/camel-aws2-ec2-sink.json | 14 + .../resources/connectors/camel-aws2-ecs-sink.json | 14 + .../resources/connectors/camel-aws2-eks-sink.json | 14 + .../connectors/camel-aws2-eventbridge-sink.json| 14 + .../resources/connectors/camel-aws2-iam-sink.json | 14 + .../resources/connectors/camel-aws2-kms-sink.json | 14 + .../connectors/camel-aws2-lambda-sink.json | 18 +- .../connectors/camel-azure-cosmosdb-sink.json | 350 +++ .../connectors/camel-azure-cosmosdb-source.json| 345 +++ .../resources/connectors/camel-coap+tcp-sink.json | 23 +- .../connectors/camel-coap+tcp-source.json |
[camel-kafka-connector] 02/02: Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch kamelets
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit e0a4d6a8d53b3a9261b9987b3544cdda59f427d3
Author: Andrea Tarocchi
AuthorDate: Sat May 15 07:59:12 2021 +0200
Related to #423 resolved a problem with marshal/unmarshal after fixin
https://issues.apache.org/jira/browse/CAMEL-16551
---
.../utils/CamelKafkaConnectMain.java | 28 +++---
.../camel/kafkaconnector/CamelSourceTaskTest.java | 5
2 files changed, 14 insertions(+), 19 deletions(-)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index 6e7dbdf..ba272d6 100644
---
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
+++
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
@@ -229,15 +229,15 @@ public class CamelKafkaConnectMain extends SimpleMain {
camelProperties.putAll(props);
//TODO: enable or delete these parameters once
https://issues.apache.org/jira/browse/CAMEL-16551 is resolved
-////dataformats
-//if (!ObjectHelper.isEmpty(marshallDataFormat)) {
-//
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLETE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
-//
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
-//}
-//if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
-//
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLETE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
-//
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
-//}
+//dataformats
+if (!ObjectHelper.isEmpty(marshallDataFormat)) {
+
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
+
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
+}
+if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
+
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
+
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
+}
//aggregator
if (!ObjectHelper.isEmpty(aggregationSize)) {
@@ -310,9 +310,9 @@ public class CamelKafkaConnectMain extends SimpleMain {
RouteTemplateDefinition rtdSource =
routeTemplate("ckcSource")
.templateParameter("fromUrl")
.templateParameter("errorHandler",
"ckcErrorHandler")
-//TODO: enable or delete these parameters once
https://issues.apache.org/jira/browse/CAMEL-16551 is resolved
-//.templateParameter("marshall", "dummyDataformat")
-//.templateParameter("unmarshall",
"dummyDataformat")
+
+.templateParameter("marshall", "dummyDataformat")
+.templateParameter("unmarshall", "dummyDataformat")
//TODO: change
CamelConnectorConfig.CAMEL_CONNECTOR_AGGREGATE_NA to ckcAggregationStrategy?
.templateParameter("aggregationStrategy",
CamelConnectorConfig.CAMEL_CONNECTOR_AGGREGATE_NAME)
@@ -327,10 +327,10 @@ public class CamelKafkaConnectMain extends SimpleMain {
ProcessorDefinition rdInTemplateSource =
rtdSource.from("{{fromUrl}}")
.errorHandler(new
ErrorHandlerBuilderRef("{{errorHandler}}"));
if (!ObjectHelper.isEmpty(marshallDataFormat)) {
-rdInTemplateSource =
rdInTemplateSource.marshal(marshallDataFormat);
+rdInTemplateSource =
rdInTemplateSource.marshal("{{marshall}}");
}
if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
-rdInTemplateSource =
rdInTemplateSource.unmarshal(unmarshallDataFormat);
+rdInTemplateSource =
rdInTemplateSource.unmarshal("{{unmarshall}}");
}
if (getContext().getRegistry().lookupByName("aggregate&
[camel-kafka-connector] 01/02: Related to #423 : caonverted source and sink to use camel-kamelets.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch kamelets
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit e3ee40f6492ee65277924166fe8a69af8ac0eab6
Author: Andrea Tarocchi
AuthorDate: Mon Apr 26 01:38:42 2021 +0200
Related to #423 : caonverted source and sink to use camel-kamelets.
---
core/pom.xml | 10 +-
.../apache/camel/kafkaconnector/CamelSinkTask.java | 5 +-
.../camel/kafkaconnector/CamelSourceTask.java | 5 +-
.../utils/CamelKafkaConnectMain.java | 272 -
.../camel/kafkaconnector/CamelSourceTaskTest.java | 10 +-
.../camel/kafkaconnector/DataFormatTest.java | 10 +-
6 files changed, 191 insertions(+), 121 deletions(-)
diff --git a/core/pom.xml b/core/pom.xml
index 4100f6a..6896ab1 100644
--- a/core/pom.xml
+++ b/core/pom.xml
@@ -53,12 +53,20 @@
org.apache.camel
-camel-kafka
+camel-kamelet
org.apache.camel
camel-core-languages
+
+org.apache.camel
+camel-kafka
+
+
+org.apache.camel
+camel-xml-jaxb
+
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
index 82c16d2..4e5a201 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
@@ -42,6 +42,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class CamelSinkTask extends SinkTask {
+public static final String KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX =
"camel.kamelet.ckcSink.";
+
public static final String KAFKA_RECORD_KEY_HEADER =
"camel.kafka.connector.record.key";
public static final String HEADER_CAMEL_PREFIX = "CamelHeader.";
public static final String PROPERTY_CAMEL_PREFIX = "CamelProperty.";
@@ -119,8 +121,9 @@ public class CamelSinkTask extends SinkTask {
CAMEL_SINK_ENDPOINT_PROPERTIES_PREFIX,
CAMEL_SINK_PATH_PROPERTIES_PREFIX);
}
+actualProps.put(KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX + "toUrl",
remoteUrl);
-cms = CamelKafkaConnectMain.builder(LOCAL_URL, remoteUrl)
+cms = CamelKafkaConnectMain.builder(LOCAL_URL, "kamelet:ckcSink")
.withProperties(actualProps)
.withUnmarshallDataFormat(unmarshaller)
.withMarshallDataFormat(marshaller)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
index 00ce145..77ce636 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
@@ -49,6 +49,7 @@ import org.slf4j.LoggerFactory;
public class CamelSourceTask extends SourceTask {
+public static final String KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX =
"camel.kamelet.ckcSource.";
public static final String HEADER_CAMEL_PREFIX = "CamelHeader.";
public static final String PROPERTY_CAMEL_PREFIX = "CamelProperty.";
@@ -145,8 +146,9 @@ public class CamelSourceTask extends SourceTask {
config.getString(CamelSourceConnectorConfig.CAMEL_SOURCE_COMPONENT_CONF),
CAMEL_SOURCE_ENDPOINT_PROPERTIES_PREFIX,
CAMEL_SOURCE_PATH_PROPERTIES_PREFIX);
}
+actualProps.put(KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"fromUrl", remoteUrl);
-cms = CamelKafkaConnectMain.builder(remoteUrl, localUrl)
+cms = CamelKafkaConnectMain.builder("kamelet:ckcSource", localUrl)
.withProperties(actualProps)
.withUnmarshallDataFormat(unmarshaller)
.withMarshallDataFormat(marshaller)
@@ -171,6 +173,7 @@ public class CamelSourceTask extends SourceTask {
consumer.start();
cms.start();
+
LOG.info("CamelSourceTask connector task started");
} catch (Exception e) {
throw new ConnectException("Failed to create and start Camel
context", e);
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index d031b20..6e7dbdf 100644
---
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConn
[camel-kafka-connector] branch kamelets updated (e0a4d6a -> 9b229ed)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch kamelets in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. discard e0a4d6a Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551 new 9b229ed Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551 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 (e0a4d6a) \ N -- N -- N refs/heads/kamelets (9b229ed) 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 1 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: .../org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java | 1 - 1 file changed, 1 deletion(-)
[camel-kafka-connector] 01/01: Related to #423 resolved a problem with marshal/unmarshal after fixin https://issues.apache.org/jira/browse/CAMEL-16551
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch kamelets
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 9b229ed862ab3bcbd5be1712ca7c00479e0d5c80
Author: Andrea Tarocchi
AuthorDate: Sat May 15 07:59:12 2021 +0200
Related to #423 resolved a problem with marshal/unmarshal after fixin
https://issues.apache.org/jira/browse/CAMEL-16551
---
.../utils/CamelKafkaConnectMain.java | 29 +++---
.../camel/kafkaconnector/CamelSourceTaskTest.java | 5
2 files changed, 14 insertions(+), 20 deletions(-)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index 6e7dbdf..036375b 100644
---
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
+++
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
@@ -228,16 +228,15 @@ public class CamelKafkaConnectMain extends SimpleMain {
Properties camelProperties = new Properties();
camelProperties.putAll(props);
-//TODO: enable or delete these parameters once
https://issues.apache.org/jira/browse/CAMEL-16551 is resolved
-////dataformats
-//if (!ObjectHelper.isEmpty(marshallDataFormat)) {
-//
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLETE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
-//
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
-//}
-//if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
-//
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLETE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
-//
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
-//}
+//dataformats
+if (!ObjectHelper.isEmpty(marshallDataFormat)) {
+
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
+
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"marshall", marshallDataFormat);
+}
+if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
+
camelProperties.put(CamelSourceTask.KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
+
camelProperties.put(CamelSinkTask.KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX +
"unmarshall", unmarshallDataFormat);
+}
//aggregator
if (!ObjectHelper.isEmpty(aggregationSize)) {
@@ -310,9 +309,9 @@ public class CamelKafkaConnectMain extends SimpleMain {
RouteTemplateDefinition rtdSource =
routeTemplate("ckcSource")
.templateParameter("fromUrl")
.templateParameter("errorHandler",
"ckcErrorHandler")
-//TODO: enable or delete these parameters once
https://issues.apache.org/jira/browse/CAMEL-16551 is resolved
-//.templateParameter("marshall", "dummyDataformat")
-//.templateParameter("unmarshall",
"dummyDataformat")
+
+.templateParameter("marshall", "dummyDataformat")
+.templateParameter("unmarshall", "dummyDataformat")
//TODO: change
CamelConnectorConfig.CAMEL_CONNECTOR_AGGREGATE_NA to ckcAggregationStrategy?
.templateParameter("aggregationStrategy",
CamelConnectorConfig.CAMEL_CONNECTOR_AGGREGATE_NAME)
@@ -327,10 +326,10 @@ public class CamelKafkaConnectMain extends SimpleMain {
ProcessorDefinition rdInTemplateSource =
rtdSource.from("{{fromUrl}}")
.errorHandler(new
ErrorHandlerBuilderRef("{{errorHandler}}"));
if (!ObjectHelper.isEmpty(marshallDataFormat)) {
-rdInTemplateSource =
rdInTemplateSource.marshal(marshallDataFormat);
+rdInTemplateSource =
rdInTemplateSource.marshal("{{marshall}}");
}
if (!ObjectHelper.isEmpty(unmarshallDataFormat)) {
-rdInTemplateSource =
rdInTemplateSource.unmarshal(unmarshallDataFormat);
+rdInTemplateSource =
rdInTemplateSource.unmarshal("{{unmarshall}}");
}
if (getCon
[camel-kafka-connector] branch main updated: Polished jenkins pipeline.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 978676e Polished jenkins pipeline.
978676e is described below
commit 978676e8460f3c6b82422f93cadffcda83d86cdf
Author: Andrea Tarocchi
AuthorDate: Wed May 26 07:53:15 2021 +0200
Polished jenkins pipeline.
---
Jenkinsfile | 8 +---
Jenkinsfile.jdk11 | 8 +---
2 files changed, 2 insertions(+), 14 deletions(-)
diff --git a/Jenkinsfile b/Jenkinsfile
index 2caafb6..c5778ee 100644
--- a/Jenkinsfile
+++ b/Jenkinsfile
@@ -58,13 +58,7 @@ pipeline {
}
}
-stage('Build & Deploy') {
-steps {
-sh "./mvnw $MAVEN_PARAMS -Dmaven.test.skip.exec=true clean"
-}
-}
-
-stage('Test') {
+stage('Build & iTest') {
steps {
sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true clean verify"
}
diff --git a/Jenkinsfile.jdk11 b/Jenkinsfile.jdk11
index a2e07e7..ba19738 100644
--- a/Jenkinsfile.jdk11
+++ b/Jenkinsfile.jdk11
@@ -58,13 +58,7 @@ pipeline {
}
}
-stage('Build & Deploy') {
-steps {
-sh "./mvnw $MAVEN_PARAMS -Dmaven.test.skip.exec=true clean
install"
-}
-}
-
-stage('Test') {
+stage('Build & iTest') {
steps {
sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true
-Dfailsafe.rerunFailingTestsCount=2 clean verify"
}
[camel-kafka-connector] 03/03: Changed maven test step targets in jenkinsfiles from isntall to verify.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit b0b6ea827e48f6857232efcd8cee69fe78f07d8f
Author: Andrea Tarocchi
AuthorDate: Tue May 25 16:20:00 2021 +0200
Changed maven test step targets in jenkinsfiles from isntall to verify.
---
Jenkinsfile | 2 +-
Jenkinsfile.jdk11 | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/Jenkinsfile b/Jenkinsfile
index bfa1f1d..2caafb6 100644
--- a/Jenkinsfile
+++ b/Jenkinsfile
@@ -66,7 +66,7 @@ pipeline {
stage('Test') {
steps {
-sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true clean install"
+sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true clean verify"
}
post {
always {
diff --git a/Jenkinsfile.jdk11 b/Jenkinsfile.jdk11
index d9312ad..a2e07e7 100644
--- a/Jenkinsfile.jdk11
+++ b/Jenkinsfile.jdk11
@@ -66,7 +66,7 @@ pipeline {
stage('Test') {
steps {
-sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true
-Dfailsafe.rerunFailingTestsCount=2 clean install"
+sh "./mvnw $MAVEN_PARAMS -DskipIntegrationTests=false
-Denable.slow.tests=true -Dmaven.test.failure.ignore=true
-Dfailsafe.rerunFailingTestsCount=2 clean verify"
}
post {
always {
[camel-kafka-connector] 01/03: Updated lates released version to 0.10.0
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit c2a7207b547bbf1823dc9ef572afe0879ea916a9
Author: Andrea Tarocchi
AuthorDate: Tue May 25 15:49:17 2021 +0200
Updated lates released version to 0.10.0
---
connectors/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/pom.xml b/connectors/pom.xml
index 2b75082..ca91e87 100644
--- a/connectors/pom.xml
+++ b/connectors/pom.xml
@@ -163,7 +163,7 @@
camel-kafka-connector-docs-maven-plugin
${project.version}
-0.9.0
+0.10.0
[camel-kafka-connector] branch main updated (4efa149 -> b0b6ea8)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from 4efa149 Updated CHANGELOG.md new c2a7207 Updated lates released version to 0.10.0 new 64c7939 chore: regen. new b0b6ea8 Changed maven test step targets in jenkinsfiles from isntall to verify. The 3 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: Jenkinsfile| 2 +- Jenkinsfile.jdk11 | 2 +- .../resources/connectors/camel-kamelet-sink.json | 6 + .../resources/connectors/camel-kamelet-source.json | 6 + .../generated/resources/camel-kamelet-sink.json| 6 + .../generated/resources/camel-kamelet-source.json | 6 + .../docs/camel-kamelet-kafka-sink-connector.adoc | 3 +- .../docs/camel-kamelet-kafka-source-connector.adoc | 3 +- .../kamelet/CamelKameletSinkConnectorConfig.java | 4 + .../kamelet/CamelKameletSourceConnectorConfig.java | 4 + connectors/pom.xml | 2 +- docs/modules/ROOT/pages/connectors.adoc| 678 ++--- .../camel-kamelet-kafka-sink-connector.adoc| 3 +- .../camel-kamelet-kafka-source-connector.adoc | 3 +- 14 files changed, 382 insertions(+), 346 deletions(-)
[camel-website] branch valdar-patch-1 created (now 8c479ca)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git. at 8c479ca Created release ckc 0.10.0 No new revisions were added by this update.
svn commit: r47901 - in /release/camel/camel-kafka-connector/0.10.0: ./ camel-kafka-connector-0.10.0-src.zip camel-kafka-connector-0.10.0-src.zip.asc camel-kafka-connector-0.10.0-src.zip.sha512
Author: valdar Date: Tue May 25 13:45:22 2021 New Revision: 47901 Log: Camel Kafka Connector 0.10.0 import. Added: release/camel/camel-kafka-connector/0.10.0/ release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip (with props) release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip.asc (with props) release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip.sha512 Added: release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip.sha512 == --- release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/0.10.0/camel-kafka-connector-0.10.0-src.zip.sha512 Tue May 25 13:45:22 2021 @@ -0,0 +1 @@ +16b9f8a9d8242ea7c7de2e380cc13c735f1e948b33e9173c1724782703dc19541e5d28554a692f10866ad0bba6781a8fd1d02d69501784d678111ea96e5875fb \ No newline at end of file
[camel-kafka-connector] branch main updated (febe316 -> 8c189cd)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. discard febe316 Updated CHANGELOG.md discard d6da91b Updated CHANGELOG.md add 94de59b updated to camel 3.10.0 add b2bfafb chore: regen. add a0aaea7 [maven-release-plugin] prepare release camel-kafka-connector-0.10.0 add 61bcfa4 [maven-release-plugin] prepare for next development iteration new e888776 Updated CHANGELOG.md new 8c189cd Updated CHANGELOG.md 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 (febe316) \ N -- N -- N refs/heads/main (8c189cd) 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 2 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: .../pom.xml| 2 +- .../pom.xml| 2 +- .../pom.xml| 2 +- archetypes/pom.xml | 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- .../connectors/camel-azure-cosmosdb-sink.json | 2 +- .../connectors/camel-azure-cosmosdb-source.json| 2 +- .../connectors/camel-salesforce-sink.json | 53 +- .../resources/connectors/camel-smpp-sink.json | 28 .../resources/connectors/camel-smpp-source.json| 28 .../resources/connectors/camel-smpps-sink.json | 28 .../resources/connectors/camel-smpps-source.json | 28 connectors/camel-activemq-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-ws-kafka-connector/pom.xml| 2 +- connectors/camel-ahc-wss-kafka-connector/pom.xml | 2 +- connectors/camel-amqp-kafka-connector/pom.xml | 2 +- connectors/camel-apns-kafka-connector/pom.xml | 2 +- connectors/camel-arangodb-kafka-connector/pom.xml | 2 +- connectors/camel-as2-kafka-connector/pom.xml | 2 +- connectors/camel-asterisk-kafka-connector/pom.xml | 2 +- connectors/camel-atlasmap-kafka-connector/pom.xml | 2 +- connectors/camel-atmos-kafka-connector/pom.xml | 2 +- .../pom.xml| 2 +- connectors/camel-atom-kafka-connector/pom.xml | 2 +- .../camel-atomix-map-kafka-connector/pom.xml | 2 +- .../camel-atomix-messaging-kafka-connector/pom.xml | 2 +- .../camel-atomix-multimap-kafka-connector/pom.xml | 2 +- .../camel-atomix-queue-kafka-connector/pom.xml | 2 +- .../camel-atomix-set-kafka-connector/pom.xml | 2 +- .../camel-atomix-value-kafka-connector/pom.xml | 2 +- connectors/camel-avro-kafka-connector/pom.xml | 2 +- .../pom.xml| 2 +- .../camel-aws2-athena-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-cw-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ddb-kafka-connector/pom.xml | 2 +- .../camel-aws2-ddbstream-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ec2-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ecs-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-eks-kafka-connector/pom.xml | 2 +- .../camel-aws2-eventbridge-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- .../pom.xml| 2 +- .../camel-aws2-kinesis-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- .../camel-aws2-lambda-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-mq-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-msk-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-s3-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ses-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-sns-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-sqs-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-sts-kafka-connector/pom.xml | 2 +- .../camel-aws2-translate-kafka-connector/pom.xml | 2 +- .../camel-azure-cosmosdb-kafka-connector/pom.xml | 2 +- .../
[camel-kafka-connector] 01/02: Updated CHANGELOG.md
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit e8887765a9e42ca3aac0c334065784a6f040a633 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Sat May 22 03:22:58 2021 + Updated CHANGELOG.md --- CHANGELOG.md | 1 + 1 file changed, 1 insertion(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index b807dc8..7b99923 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -18,6 +18,7 @@ - Salesforce Sink Connector does not honour `offset.flush.interval.ms` [\#1181](https://github.com/apache/camel-kafka-connector/issues/1181) - Upgrade to Strimzi 0.23.0 [\#1173](https://github.com/apache/camel-kafka-connector/issues/1173) - Camel Rest Kafka Connector - Issue with Kubernetes Rest connector. [\#1171](https://github.com/apache/camel-kafka-connector/issues/1171) +- Upgrade to Strimzi 0.23.0 RC [\#1166](https://github.com/apache/camel-kafka-connector/issues/1166) - AWS SNS seems to be broken with Camel 3.9 and above [\#1156](https://github.com/apache/camel-kafka-connector/issues/1156) - Jackson conflicts causing Azure Storage Blob tests to fail [\#1147](https://github.com/apache/camel-kafka-connector/issues/1147) - Upgrade to Kafka 2.8.0 [\#1145](https://github.com/apache/camel-kafka-connector/issues/1145)
[camel-kafka-connector] 02/02: Updated CHANGELOG.md
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 8c189cd220926e96b010e276899e182308c3da04 Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Sun May 23 03:33:50 2021 + Updated CHANGELOG.md --- CHANGELOG.md | 66 1 file changed, 35 insertions(+), 31 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 7b99923..9b616fc 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -2,37 +2,7 @@ ## [Unreleased](https://github.com/apache/camel-kafka-connector/tree/HEAD) -[Full Changelog](https://github.com/apache/camel-kafka-connector/compare/camel-kafka-connector-0.9.0...HEAD) - -**Implemented enhancements:** - -- Verify that sha512 files are correctly published during next release [\#162](https://github.com/apache/camel-kafka-connector/issues/162) - -**Fixed bugs:** - -- HTTPS-sink-connector duplicates protocol [\#1077](https://github.com/apache/camel-kafka-connector/issues/1077) -- MongoDB tests failing with Camel master [\#974](https://github.com/apache/camel-kafka-connector/issues/974) - -**Closed issues:** - -- Salesforce Sink Connector does not honour `offset.flush.interval.ms` [\#1181](https://github.com/apache/camel-kafka-connector/issues/1181) -- Upgrade to Strimzi 0.23.0 [\#1173](https://github.com/apache/camel-kafka-connector/issues/1173) -- Camel Rest Kafka Connector - Issue with Kubernetes Rest connector. [\#1171](https://github.com/apache/camel-kafka-connector/issues/1171) -- Upgrade to Strimzi 0.23.0 RC [\#1166](https://github.com/apache/camel-kafka-connector/issues/1166) -- AWS SNS seems to be broken with Camel 3.9 and above [\#1156](https://github.com/apache/camel-kafka-connector/issues/1156) -- Jackson conflicts causing Azure Storage Blob tests to fail [\#1147](https://github.com/apache/camel-kafka-connector/issues/1147) -- Upgrade to Kafka 2.8.0 [\#1145](https://github.com/apache/camel-kafka-connector/issues/1145) -- example of a sql source connector url pattern [\#1144](https://github.com/apache/camel-kafka-connector/issues/1144) -- Upstream CI failures [\#1143](https://github.com/apache/camel-kafka-connector/issues/1143) -- Align master to latest camel snapshot [\#1133](https://github.com/apache/camel-kafka-connector/issues/1133) -- Connector Kafka Idempotency Crash Resilience [\#1128](https://github.com/apache/camel-kafka-connector/issues/1128) -- Release 0.9.0 [\#1127](https://github.com/apache/camel-kafka-connector/issues/1127) -- NetworkUtils should be able to hold a free port for later usage [\#1109](https://github.com/apache/camel-kafka-connector/issues/1109) -- Google pub/sub: endpoint option cannot be set [\#1086](https://github.com/apache/camel-kafka-connector/issues/1086) -- Missing message key on outbound using Camel Kafka KafkaConnector [\#988](https://github.com/apache/camel-kafka-connector/issues/988) -- Question: S3 source connector pulls duplicate data when task.max \> 1 [\#959](https://github.com/apache/camel-kafka-connector/issues/959) -- add itests for camel-cxf-kafka-connector [\#873](https://github.com/apache/camel-kafka-connector/issues/873) -- SJMS2 connector fails with qpid JmsConnectionFactory [\#751](https://github.com/apache/camel-kafka-connector/issues/751) +[Full Changelog](https://github.com/apache/camel-kafka-connector/compare/camel-kafka-connector-0.10.0...HEAD) **Merged pull requests:** @@ -310,6 +280,40 @@ - Minor changes to docs - correct the camel-log and camel-timer properties file names, verbiage change on untar/unzip section. [\#639](https://github.com/apache/camel-kafka-connector/pull/639) ([cunningt](https://github.com/cunningt)) - Decouple the Elasticsearch client from the service to simplify moving the services to Camel core [\#638](https://github.com/apache/camel-kafka-connector/pull/638) ([orpiske](https://github.com/orpiske)) +## [camel-kafka-connector-0.10.0](https://github.com/apache/camel-kafka-connector/tree/camel-kafka-connector-0.10.0) (2021-05-22) + +[Full Changelog](https://github.com/apache/camel-kafka-connector/compare/camel-kafka-connector-0.9.0...camel-kafka-connector-0.10.0) + +**Implemented enhancements:** + +- Verify that sha512 files are correctly published during next release [\#162](https://github.com/apache/camel-kafka-connector/issues/162) + +**Fixed bugs:** + +- HTTPS-sink-connector duplicates protocol [\#1077](https://github.com/apache/camel-kafka-connector/issues/1077) +- MongoDB tests failing with Camel master [\#974](https://github.com/apache/camel-kafka-connector/issues/974) + +**Closed issues:** + +- Salesforce Sink Connector does not honour `offset.flush.interval.ms` [\#1181](https://github.com/apache/camel-kafka-connector/issues/1181) +- Upgrade to Strimzi 0.23.0 [\#1173](https://github.com/apache/ca
[camel-kafka-connector] branch camel-kafka-connector-0.10.x created (now a0aaea7)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.10.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at a0aaea7 [maven-release-plugin] prepare release camel-kafka-connector-0.10.0 This branch includes the following new commits: new 94de59b updated to camel 3.10.0 new b2bfafb chore: regen. new a0aaea7 [maven-release-plugin] prepare release camel-kafka-connector-0.10.0 The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] 01/03: updated to camel 3.10.0
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.10.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 94de59bc153f79712768c13e4b626ed3ef7d5fd0 Author: Andrea Tarocchi AuthorDate: Sat May 22 11:57:29 2021 +0200 updated to camel 3.10.0 --- parent/pom.xml | 2 +- pom.xml| 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/parent/pom.xml b/parent/pom.xml index e9d49d4..3ec45e1 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -28,7 +28,7 @@ UTF-8 2.8.0 -3.10.0-SNAPSHOT +3.10.0 1.3.2.Final 4.5.6.Final 1.8 diff --git a/pom.xml b/pom.xml index 7531e03..123663b 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,7 @@ org.apache.camel camel-dependencies -3.10.0-SNAPSHOT +3.10.0 org.apache.camel.kafkaconnector
[camel-kafka-connector] 02/03: chore: regen.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch camel-kafka-connector-0.10.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit b2bfafbe02a55bb66b71cd6620db42635b55ba74
Author: Andrea Tarocchi
AuthorDate: Sat May 22 11:57:42 2021 +0200
chore: regen.
---
.../connectors/camel-azure-cosmosdb-sink.json | 2 +-
.../connectors/camel-azure-cosmosdb-source.json| 2 +-
.../connectors/camel-salesforce-sink.json | 53 +-
.../resources/connectors/camel-smpp-sink.json | 28
.../resources/connectors/camel-smpp-source.json| 28
.../resources/connectors/camel-smpps-sink.json | 28
.../resources/connectors/camel-smpps-source.json | 28
.../resources/camel-azure-cosmosdb-sink.json | 2 +-
.../resources/camel-azure-cosmosdb-source.json | 2 +-
.../camel-azure-cosmosdb-kafka-sink-connector.adoc | 2 +-
...amel-azure-cosmosdb-kafka-source-connector.adoc | 2 +-
.../generated/resources/camel-salesforce-sink.json | 53 +-
.../camel-salesforce-kafka-sink-connector.adoc | 12 +
.../CamelSalesforceSinkConnectorConfig.java| 34 +-
.../src/generated/resources/camel-smpp-sink.json | 28
.../src/generated/resources/camel-smpp-source.json | 28
.../main/docs/camel-smpp-kafka-sink-connector.adoc | 6 +--
.../docs/camel-smpp-kafka-source-connector.adoc| 6 +--
.../smpp/CamelSmppSinkConnectorConfig.java | 16 ---
.../smpp/CamelSmppSourceConnectorConfig.java | 16 ---
.../src/generated/resources/camel-smpps-sink.json | 28
.../generated/resources/camel-smpps-source.json| 28
.../docs/camel-smpps-kafka-sink-connector.adoc | 6 +--
.../docs/camel-smpps-kafka-source-connector.adoc | 6 +--
.../smpps/CamelSmppsSinkConnectorConfig.java | 16 ---
.../smpps/CamelSmppsSourceConnectorConfig.java | 16 ---
.../camel-azure-cosmosdb-kafka-sink-connector.adoc | 2 +-
...amel-azure-cosmosdb-kafka-source-connector.adoc | 2 +-
.../camel-salesforce-kafka-sink-connector.adoc | 12 +
.../camel-smpp-kafka-sink-connector.adoc | 6 +--
.../camel-smpp-kafka-source-connector.adoc | 6 +--
.../camel-smpps-kafka-sink-connector.adoc | 6 +--
.../camel-smpps-kafka-source-connector.adoc| 6 +--
33 files changed, 25 insertions(+), 491 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink.json
index 4078284..00fe677 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink.json
@@ -6,7 +6,7 @@
"id": "camel-azure-cosmosdb-sink",
"type": "sink",
"version": "0.10.0-SNAPSHOT",
- "description": "To read and write records to the CosmosDB
database on Azure cloud platform."
+ "description": "Azure Cosmos DB is Microsofts globally
distributed, multi-model database service for operational and analytics
workloads. It offers multi-mastering feature by automatically scaling
throughput, compute, and storage. This component interacts with Azure CosmosDB
through Azure SQL API"
},
"properties": {
"camel.sink.path.databaseName": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-source.json
index 53a0ae0..fc663a9 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-source.json
@@ -6,7 +6,7 @@
"id": "camel-azure-cosmosdb-source",
"type": "source",
"version": "0.10.0-SNAPSHOT",
- "description": "To read and write records to the CosmosDB
database on Azure cloud platform."
+ "description": "Azure Cosmos DB is Microsofts globally
distributed, multi-model database service for operational and analytics
workloads. It offers multi-mastering feature by automatically scaling
throughput, compute, and storage. This component interacts with Azure CosmosDB
through Azure SQL API"
},
"properties": {
"camel.source.path.databa
[camel-kafka-connector] annotated tag camel-kafka-connector-0.10.0 created (now bacf457)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.10.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at bacf457 (tag) tagging a0aaea752f7baf5665524dbfe784c67b4b5fe90d (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Sat May 22 12:42:08 2021 +0200 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.10.0 --- No new revisions were added by this update.
[camel-kafka-connector] tag camel-kafka-connector-0.10.0 updated (bacf457 -> 392c128)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.10.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.10.0 was modified! *** from bacf457 (tag) to 392c128 (commit) from a0aaea7 [maven-release-plugin] prepare release camel-kafka-connector-0.10.0 new 392c128 [after release perform chore]: regen catalog descriptors with new version The 1 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-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json | 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-apns-sink.json | 2 +- .../src/generated/resources/connectors/camel-apns-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json| 2 +- .../src/generated/resources/connectors/camel-as2-source.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-source.json| 2 +- .../resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../generated/resources/connectors/camel-atomix-multimap-sink.json| 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-athena-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-cw-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-ddb-sink.json | 2 +- .../generated/resources/connectors/camel-aws2-ddbstream-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ec2-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ecs-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-eks-sink.json | 2 +- .../generated/resources/connectors/camel-aws2-eventbridge-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../resources/connectors/camel-aws2-kinesis-firehose-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-kinesis-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kinesis-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-lambda-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-mq-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-msk-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-s3-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-s3-source.json | 2 +- .../src
[camel-kafka-connector] branch main updated (6e0817d -> 662b289)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from 6e0817d Updated CHANGELOG.md new c11375e fix #1114 : camel-salesforce-kafka-connector missing dependency library new 662b289 fix #389 : Improve documentation TOC The 2 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/camel-kafka-sink.json | 14 + .../docs/camel-kafka-kafka-sink-connector.adoc |4 +- .../kafka/CamelKafkaSinkConnectorConfig.java |8 + .../camel-salesforce-kafka-connector/pom.xml |7 - docs/modules/ROOT/nav.adoc | 1772 ++-- docs/modules/ROOT/pages/connectors.adoc| 350 .../camel-activemq-kafka-sink-connector.adoc |4 + .../camel-activemq-kafka-source-connector.adoc |4 + .../connectors/camel-ahc-kafka-sink-connector.adoc |4 + .../camel-ahc-ws-kafka-sink-connector.adoc |4 + .../camel-ahc-ws-kafka-source-connector.adoc |4 + .../camel-ahc-wss-kafka-sink-connector.adoc|4 + .../camel-ahc-wss-kafka-source-connector.adoc |4 + .../camel-amqp-kafka-sink-connector.adoc |4 + .../camel-amqp-kafka-source-connector.adoc |4 + .../camel-apns-kafka-sink-connector.adoc |4 + .../camel-apns-kafka-source-connector.adoc |4 + .../camel-arangodb-kafka-sink-connector.adoc |4 + .../connectors/camel-as2-kafka-sink-connector.adoc |4 + .../camel-as2-kafka-source-connector.adoc |4 + .../camel-asterisk-kafka-sink-connector.adoc |4 + .../camel-asterisk-kafka-source-connector.adoc |4 + .../camel-atlasmap-kafka-sink-connector.adoc |4 + .../camel-atmos-kafka-sink-connector.adoc |4 + .../camel-atmos-kafka-source-connector.adoc|4 + ...-atmosphere-websocket-kafka-sink-connector.adoc |4 + ...tmosphere-websocket-kafka-source-connector.adoc |4 + .../camel-atom-kafka-source-connector.adoc |4 + .../camel-atomix-map-kafka-sink-connector.adoc |4 + .../camel-atomix-map-kafka-source-connector.adoc |4 + ...amel-atomix-messaging-kafka-sink-connector.adoc |4 + ...el-atomix-messaging-kafka-source-connector.adoc |4 + ...camel-atomix-multimap-kafka-sink-connector.adoc |4 + .../camel-atomix-queue-kafka-sink-connector.adoc |4 + .../camel-atomix-queue-kafka-source-connector.adoc |4 + .../camel-atomix-set-kafka-sink-connector.adoc |4 + .../camel-atomix-set-kafka-source-connector.adoc |4 + .../camel-atomix-value-kafka-sink-connector.adoc |4 + .../camel-atomix-value-kafka-source-connector.adoc |4 + .../camel-avro-kafka-sink-connector.adoc |4 + .../camel-avro-kafka-source-connector.adoc |4 + ...l-aws-secrets-manager-kafka-sink-connector.adoc |4 + .../camel-aws2-athena-kafka-sink-connector.adoc|4 + .../camel-aws2-cw-kafka-sink-connector.adoc|4 + .../camel-aws2-ddb-kafka-sink-connector.adoc |4 + ...amel-aws2-ddbstream-kafka-source-connector.adoc |4 + .../camel-aws2-ec2-kafka-sink-connector.adoc |4 + .../camel-aws2-ecs-kafka-sink-connector.adoc |4 + .../camel-aws2-eks-kafka-sink-connector.adoc |4 + ...amel-aws2-eventbridge-kafka-sink-connector.adoc |4 + .../camel-aws2-iam-kafka-sink-connector.adoc |4 + ...aws2-kinesis-firehose-kafka-sink-connector.adoc |4 + .../camel-aws2-kinesis-kafka-sink-connector.adoc |4 + .../camel-aws2-kinesis-kafka-source-connector.adoc |4 + .../camel-aws2-kms-kafka-sink-connector.adoc |4 + .../camel-aws2-lambda-kafka-sink-connector.adoc|4 + .../camel-aws2-mq-kafka-sink-connector.adoc|4 + .../camel-aws2-msk-kafka-sink-connector.adoc |4 + .../camel-aws2-s3-kafka-sink-connector.adoc|2 + .../camel-aws2-s3-kafka-source-connector.adoc |2 + .../camel-aws2-ses-kafka-sink-connector.adoc |4 + .../camel-aws2-sns-kafka-sink-connector.adoc |4 + .../camel-aws2-sqs-kafka-sink-connector.adoc |4 + .../camel-aws2-sqs-kafka-source-connector.adoc |4 + .../camel-aws2-sts-kafka-sink-connector.adoc |4 + .../camel-aws2-translate-kafka-sink-connector.adoc |4 + .../camel-azure-cosmosdb-kafka-sink-connector.adoc |4 + ...amel-azure-cosmosdb-kafka-source-connector.adoc |4 + ...camel-azure-eventhubs-kafka-sink-connector.adoc |4 + ...mel-azure-eventhubs-kafka-source-connector.adoc |4 + ...el-azure-storage-blob-kafka-sink-connector.adoc |4
[camel-kafka-connector] 01/02: fix #1114 : camel-salesforce-kafka-connector missing dependency library
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit c11375e27ed9769f83f488e6197a01bc72968292 Author: Andrea Tarocchi AuthorDate: Thu Jun 3 11:16:39 2021 +0200 fix #1114 : camel-salesforce-kafka-connector missing dependency library --- connectors/camel-salesforce-kafka-connector/pom.xml| 7 --- tests/itests-salesforce/pom.xml| 7 --- .../kafkaconnector/salesforce/clients/SalesforceCliContainer.java | 2 +- .../kafkaconnector/salesforce/sink/CamelSinkSalesforceITCase.java | 2 ++ .../salesforce/source/CamelSourceSalesforceITCase.java | 3 +++ 5 files changed, 6 insertions(+), 15 deletions(-) diff --git a/connectors/camel-salesforce-kafka-connector/pom.xml b/connectors/camel-salesforce-kafka-connector/pom.xml index f97614f..35a3585 100644 --- a/connectors/camel-salesforce-kafka-connector/pom.xml +++ b/connectors/camel-salesforce-kafka-connector/pom.xml @@ -43,13 +43,6 @@ org.apache.camel camel-salesforce - - - - org.eclipse.jetty - jetty-http - - diff --git a/tests/itests-salesforce/pom.xml b/tests/itests-salesforce/pom.xml index 81ef830..9517cda 100644 --- a/tests/itests-salesforce/pom.xml +++ b/tests/itests-salesforce/pom.xml @@ -49,13 +49,6 @@ org.apache.camel camel-salesforce - - - -org.eclipse.jetty -jetty-http - - diff --git a/tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SalesforceCliContainer.java b/tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SalesforceCliContainer.java index 4b5a257..8508bee 100644 --- a/tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SalesforceCliContainer.java +++ b/tests/itests-salesforce/src/test/java/org/apache/camel/kafkaconnector/salesforce/clients/SalesforceCliContainer.java @@ -30,7 +30,7 @@ public class SalesforceCliContainer extends GenericContainer
[camel-kafka-connector] 01/02: Updatede to camel 3.11.0-SNAPSHOT
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch updateTO3.11 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 771f5ff0cb062d7af347b95a24da3607b0d2d6cf Author: Andrea Tarocchi AuthorDate: Mon May 24 14:02:46 2021 +0200 Updatede to camel 3.11.0-SNAPSHOT --- parent/pom.xml | 2 +- pom.xml| 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/parent/pom.xml b/parent/pom.xml index 38783f0..7db3e2c 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -28,7 +28,7 @@ UTF-8 2.8.0 -3.10.0 +3.11.0-SNAPSHOT 1.3.2.Final 4.5.6.Final 1.8 diff --git a/pom.xml b/pom.xml index 8aa1f54..03735e8 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,7 @@ org.apache.camel camel-dependencies -3.10.0 +3.11.0-SNAPSHOT org.apache.camel.kafkaconnector
[camel-kafka-connector] branch updateTO3.11 created (now 90052f6)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch updateTO3.11 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 90052f6 chore: regen. This branch includes the following new commits: new 771f5ff Updatede to camel 3.11.0-SNAPSHOT new 90052f6 chore: regen. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] branch main updated (8c189cd -> a6c4115)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from 8c189cd Updated CHANGELOG.md new 28051e3 Updatede to camel 3.11.0-SNAPSHOT new a6c4115 chore: regen. The 2 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: .../resources/connectors/camel-activemq-sink.json | 2 +- .../connectors/camel-activemq-source.json | 2 +- .../resources/connectors/camel-ahc-sink.json | 2 +- .../resources/connectors/camel-ahc-ws-sink.json| 2 +- .../resources/connectors/camel-ahc-ws-source.json | 2 +- .../resources/connectors/camel-ahc-wss-sink.json | 2 +- .../resources/connectors/camel-ahc-wss-source.json | 2 +- .../resources/connectors/camel-amqp-sink.json | 2 +- .../resources/connectors/camel-amqp-source.json| 2 +- .../resources/connectors/camel-apns-sink.json | 2 +- .../resources/connectors/camel-apns-source.json| 2 +- .../resources/connectors/camel-arangodb-sink.json | 2 +- .../resources/connectors/camel-as2-sink.json | 2 +- .../resources/connectors/camel-as2-source.json | 2 +- .../resources/connectors/camel-asterisk-sink.json | 2 +- .../connectors/camel-asterisk-source.json | 2 +- .../resources/connectors/camel-atlasmap-sink.json | 2 +- .../resources/connectors/camel-atmos-sink.json | 2 +- .../resources/connectors/camel-atmos-source.json | 2 +- .../camel-atmosphere-websocket-sink.json | 2 +- .../camel-atmosphere-websocket-source.json | 2 +- .../resources/connectors/camel-atom-source.json| 2 +- .../connectors/camel-atomix-map-sink.json | 2 +- .../connectors/camel-atomix-map-source.json| 2 +- .../connectors/camel-atomix-messaging-sink.json| 2 +- .../connectors/camel-atomix-messaging-source.json | 2 +- .../connectors/camel-atomix-multimap-sink.json | 2 +- .../connectors/camel-atomix-queue-sink.json| 2 +- .../connectors/camel-atomix-queue-source.json | 2 +- .../connectors/camel-atomix-set-sink.json | 2 +- .../connectors/camel-atomix-set-source.json| 2 +- .../connectors/camel-atomix-value-sink.json| 2 +- .../connectors/camel-atomix-value-source.json | 2 +- .../resources/connectors/camel-avro-sink.json | 2 +- .../resources/connectors/camel-avro-source.json| 2 +- .../connectors/camel-aws-secrets-manager-sink.json | 2 +- .../connectors/camel-aws2-athena-sink.json | 2 +- .../resources/connectors/camel-aws2-cw-sink.json | 2 +- .../resources/connectors/camel-aws2-ddb-sink.json | 2 +- .../connectors/camel-aws2-ddbstream-source.json| 2 +- .../resources/connectors/camel-aws2-ec2-sink.json | 2 +- .../resources/connectors/camel-aws2-ecs-sink.json | 2 +- .../resources/connectors/camel-aws2-eks-sink.json | 2 +- .../connectors/camel-aws2-eventbridge-sink.json| 2 +- .../resources/connectors/camel-aws2-iam-sink.json | 2 +- .../camel-aws2-kinesis-firehose-sink.json | 2 +- .../connectors/camel-aws2-kinesis-sink.json| 2 +- .../connectors/camel-aws2-kinesis-source.json | 2 +- .../resources/connectors/camel-aws2-kms-sink.json | 2 +- .../connectors/camel-aws2-lambda-sink.json | 2 +- .../resources/connectors/camel-aws2-mq-sink.json | 2 +- .../resources/connectors/camel-aws2-msk-sink.json | 2 +- .../resources/connectors/camel-aws2-s3-sink.json | 2 +- .../resources/connectors/camel-aws2-s3-source.json | 2 +- .../resources/connectors/camel-aws2-ses-sink.json | 2 +- .../resources/connectors/camel-aws2-sns-sink.json | 2 +- .../resources/connectors/camel-aws2-sqs-sink.json | 2 +- .../connectors/camel-aws2-sqs-source.json | 2 +- .../resources/connectors/camel-aws2-sts-sink.json | 2 +- .../connectors/camel-aws2-translate-sink.json | 2 +- .../connectors/camel-azure-cosmosdb-sink.json | 4 +- .../connectors/camel-azure-cosmosdb-source.json| 4 +- .../connectors/camel-azure-eventhubs-sink.json | 2 +- .../connectors/camel-azure-eventhubs-source.json | 2 +- .../connectors/camel-azure-storage-blob-sink.json | 2 +- .../camel-azure-storage-blob-source.json | 2 +- .../camel-azure-storage-datalake-sink.json | 2 +- .../camel-azure-storage-datalake-source.json | 2 +- .../connectors/camel-azure-storage-queue-sink.json | 2 +- .../camel-azure-storage-queue-source.json | 2 +- .../resources/connectors/camel-bean-sink.json | 2 +- .../resources/connectors/camel-beanstalk-sink.json | 2 +- .../connectors/camel-beanstalk-source.json | 2 +- .../resources/connectors/camel-box-
[camel-kafka-connector] 01/02: Updatede to camel 3.11.0-SNAPSHOT
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 28051e384cb5a4563400a99e62ee91b2706c956c Author: Andrea Tarocchi AuthorDate: Mon May 24 14:02:46 2021 +0200 Updatede to camel 3.11.0-SNAPSHOT --- parent/pom.xml | 2 +- pom.xml| 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/parent/pom.xml b/parent/pom.xml index 38783f0..7db3e2c 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -28,7 +28,7 @@ UTF-8 2.8.0 -3.10.0 +3.11.0-SNAPSHOT 1.3.2.Final 4.5.6.Final 1.8 diff --git a/pom.xml b/pom.xml index 8aa1f54..03735e8 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,7 @@ org.apache.camel camel-dependencies -3.10.0 +3.11.0-SNAPSHOT org.apache.camel.kafkaconnector
[camel-kafka-connector] 02/02: chore: regen.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch kamelets
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 5df87a0628a7d1ad801507b125ff1fe1a6f971f7
Author: Andrea Tarocchi
AuthorDate: Mon Apr 26 01:38:56 2021 +0200
chore: regen.
---
.../src/generated/resources/connectors/camel-cql-sink.json | 4 ++--
.../src/generated/resources/connectors/camel-cql-source.json | 4 ++--
.../src/generated/resources/connectors/camel-solr-sink.json | 7 +++
.../src/generated/resources/connectors/camel-solrCloud-sink.json | 7 +++
.../src/generated/resources/connectors/camel-solrs-sink.json | 7 +++
.../resources/connectors/camel-twitter-timeline-sink.json| 9 -
.../resources/connectors/camel-twitter-timeline-source.json | 9 -
.../src/generated/resources/camel-cql-sink.json | 4 ++--
.../src/generated/resources/camel-cql-source.json| 4 ++--
.../src/main/docs/camel-cql-kafka-sink-connector.adoc| 4 ++--
.../src/main/docs/camel-cql-kafka-source-connector.adoc | 4 ++--
.../camel/kafkaconnector/cql/CamelCqlSinkConnectorConfig.java| 4 ++--
.../camel/kafkaconnector/cql/CamelCqlSourceConnectorConfig.java | 4 ++--
.../src/generated/resources/camel-solr-sink.json | 7 +++
.../src/main/docs/camel-solr-kafka-sink-connector.adoc | 3 ++-
.../camel/kafkaconnector/solr/CamelSolrSinkConnectorConfig.java | 4
.../src/generated/resources/camel-solrCloud-sink.json| 7 +++
.../src/main/docs/camel-solrCloud-kafka-sink-connector.adoc | 3 ++-
.../solrcloud/CamelSolrcloudSinkConnectorConfig.java | 4
.../src/generated/resources/camel-solrs-sink.json| 7 +++
.../src/main/docs/camel-solrs-kafka-sink-connector.adoc | 3 ++-
.../kafkaconnector/solrs/CamelSolrsSinkConnectorConfig.java | 4
.../src/generated/resources/camel-twitter-timeline-sink.json | 9 -
.../src/generated/resources/camel-twitter-timeline-source.json | 9 -
.../main/docs/camel-twitter-timeline-kafka-sink-connector.adoc | 5 +++--
.../main/docs/camel-twitter-timeline-kafka-source-connector.adoc | 5 +++--
.../docs/examples/CamelTwittertimelineSinkConnector.properties | 2 +-
.../docs/examples/CamelTwittertimelineSourceConnector.properties | 2 +-
.../twittertimeline/CamelTwittertimelineSinkConnectorConfig.java | 6 +-
.../CamelTwittertimelineSourceConnectorConfig.java | 6 +-
.../ROOT/pages/connectors/camel-cql-kafka-sink-connector.adoc| 4 ++--
.../ROOT/pages/connectors/camel-cql-kafka-source-connector.adoc | 4 ++--
.../ROOT/pages/connectors/camel-solr-kafka-sink-connector.adoc | 3 ++-
.../pages/connectors/camel-solrCloud-kafka-sink-connector.adoc | 3 ++-
.../ROOT/pages/connectors/camel-solrs-kafka-sink-connector.adoc | 3 ++-
.../connectors/camel-twitter-timeline-kafka-sink-connector.adoc | 5 +++--
.../camel-twitter-timeline-kafka-source-connector.adoc | 5 +++--
37 files changed, 142 insertions(+), 42 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-sink.json
index c16e57a..e54b6b5 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-sink.json
@@ -17,13 +17,13 @@
},
"camel.sink.path.hosts": {
"name": "camel.sink.path.hosts",
- "description": "Hostname(s) cassansdra server(s).
Multiple hosts can be separated by comma.",
+ "description": "Hostname(s) Cassandra server(s).
Multiple hosts can be separated by comma.",
"priority": "MEDIUM",
"required": "false"
},
"camel.sink.path.port": {
"name": "camel.sink.path.port",
- "description": "Port number of cassansdra server(s)",
+ "description": "Port number of Cassandra server(s)",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-source.json
index e2276f1..dc6bf84 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-cql-source.json
+++
b/camel-k
[camel-kafka-connector] 01/02: Related to #423 : caonverted source and sink to use camel-kamelets.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch kamelets
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit ae61051d5120acc595afe7f489faf52cef4dfd4f
Author: Andrea Tarocchi
AuthorDate: Mon Apr 26 01:38:42 2021 +0200
Related to #423 : caonverted source and sink to use camel-kamelets.
---
core/pom.xml | 10 +-
.../apache/camel/kafkaconnector/CamelSinkTask.java | 5 +-
.../camel/kafkaconnector/CamelSourceTask.java | 5 +-
.../utils/CamelKafkaConnectMain.java | 272 -
.../camel/kafkaconnector/CamelSourceTaskTest.java | 10 +-
.../camel/kafkaconnector/DataFormatTest.java | 10 +-
6 files changed, 191 insertions(+), 121 deletions(-)
diff --git a/core/pom.xml b/core/pom.xml
index 4100f6a..6896ab1 100644
--- a/core/pom.xml
+++ b/core/pom.xml
@@ -53,12 +53,20 @@
org.apache.camel
-camel-kafka
+camel-kamelet
org.apache.camel
camel-core-languages
+
+org.apache.camel
+camel-kafka
+
+
+org.apache.camel
+camel-xml-jaxb
+
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
index 82c16d2..4e5a201 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
@@ -42,6 +42,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class CamelSinkTask extends SinkTask {
+public static final String KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX =
"camel.kamelet.ckcSink.";
+
public static final String KAFKA_RECORD_KEY_HEADER =
"camel.kafka.connector.record.key";
public static final String HEADER_CAMEL_PREFIX = "CamelHeader.";
public static final String PROPERTY_CAMEL_PREFIX = "CamelProperty.";
@@ -119,8 +121,9 @@ public class CamelSinkTask extends SinkTask {
CAMEL_SINK_ENDPOINT_PROPERTIES_PREFIX,
CAMEL_SINK_PATH_PROPERTIES_PREFIX);
}
+actualProps.put(KAMELET_SINK_TEMPLATE_PARAMETERS_PREFIX + "toUrl",
remoteUrl);
-cms = CamelKafkaConnectMain.builder(LOCAL_URL, remoteUrl)
+cms = CamelKafkaConnectMain.builder(LOCAL_URL, "kamelet:ckcSink")
.withProperties(actualProps)
.withUnmarshallDataFormat(unmarshaller)
.withMarshallDataFormat(marshaller)
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
index 00ce145..77ce636 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java
@@ -49,6 +49,7 @@ import org.slf4j.LoggerFactory;
public class CamelSourceTask extends SourceTask {
+public static final String KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX =
"camel.kamelet.ckcSource.";
public static final String HEADER_CAMEL_PREFIX = "CamelHeader.";
public static final String PROPERTY_CAMEL_PREFIX = "CamelProperty.";
@@ -145,8 +146,9 @@ public class CamelSourceTask extends SourceTask {
config.getString(CamelSourceConnectorConfig.CAMEL_SOURCE_COMPONENT_CONF),
CAMEL_SOURCE_ENDPOINT_PROPERTIES_PREFIX,
CAMEL_SOURCE_PATH_PROPERTIES_PREFIX);
}
+actualProps.put(KAMELET_SOURCE_TEMPLATE_PARAMETERS_PREFIX +
"fromUrl", remoteUrl);
-cms = CamelKafkaConnectMain.builder(remoteUrl, localUrl)
+cms = CamelKafkaConnectMain.builder("kamelet:ckcSource", localUrl)
.withProperties(actualProps)
.withUnmarshallDataFormat(unmarshaller)
.withMarshallDataFormat(marshaller)
@@ -171,6 +173,7 @@ public class CamelSourceTask extends SourceTask {
consumer.start();
cms.start();
+
LOG.info("CamelSourceTask connector task started");
} catch (Exception e) {
throw new ConnectException("Failed to create and start Camel
context", e);
diff --git
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java
index d031b20..6e7dbdf 100644
---
a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConn
[camel-kafka-connector] branch kamelets created (now 5df87a0)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch kamelets in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 5df87a0 chore: regen. This branch includes the following new commits: new ae61051 Related to #423 : caonverted source and sink to use camel-kamelets. new 5df87a0 chore: regen. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel] branch CAMEL-16547 updated (b9f7f64 -> 8599501)
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch CAMEL-16547
in repository https://gitbox.apache.org/repos/asf/camel.git.
from b9f7f64 CAMEL-16547: camel-kamelet - camel-kamelet don't bind
properties in this form:
add 4043ada CAMEL-16569: amel-kamelet don't check for duplicate id routes
during route creation from a template
add 8599501 CAMEL-16547: camel-kamelet don't bind properties in this
form: camel.component.kamelet.template-properties[templateId]
No new revisions were added by this update.
Summary of changes:
components/camel-kamelet/pom.xml | 5 ++
.../camel/component/kamelet/KameletComponent.java | 2 +-
.../kamelet/KameletComponentPropertiesTest.java| 92 ++
...sTest.java => KameletGlobalPropertiesTest.java} | 15 +++-
.../camel/component/kamelet/KameletRouteTest.java | 18 -
.../src/test/resources/log4j2.properties | 2 +-
... FailedToCreateRouteFromTemplateException.java} | 20 +++--
.../java/org/apache/camel/impl/DefaultModel.java | 9 +++
8 files changed, 151 insertions(+), 12 deletions(-)
create mode 100644
components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/KameletComponentPropertiesTest.java
rename
components/camel-kamelet/src/test/java/org/apache/camel/component/kamelet/{KameletPropertiesTest.java
=> KameletGlobalPropertiesTest.java} (93%)
copy
core/camel-api/src/main/java/org/apache/camel/{FailedToStartRouteException.java
=> FailedToCreateRouteFromTemplateException.java} (55%)
