You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/02/16 12:57:42 UTC

[camel-kafka-connector] branch master-for-0.8.0 created (now 55e21bc)

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch master-for-0.8.0
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.


      at 55e21bc  Regen

This branch includes the following new commits:

     new 145a8af  Merge camel-master to master
     new 55e21bc  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] 02/02: Regen

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master-for-0.8.0
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 55e21bc86511f86da4d1ae278d7ecb67a14c10a5
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Feb 16 13:56:37 2021 +0100

    Regen
---
 .../docs/camel-jclouds-kafka-sink-connector.adoc    |  4 ----
 .../docs/camel-jclouds-kafka-source-connector.adoc  |  4 ----
 .../docs/camel-jsonata-kafka-sink-connector.adoc    |  4 ----
 docs/modules/ROOT/nav.adoc                          | 21 ---------------------
 .../camel-jclouds-kafka-sink-connector.adoc         |  4 ----
 .../camel-jclouds-kafka-source-connector.adoc       |  4 ----
 .../camel-jsonata-kafka-sink-connector.adoc         |  4 ----
 7 files changed, 45 deletions(-)

diff --git a/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-sink-connector.adoc b/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-sink-connector.adoc
index 11df96a..153358b 100644
--- a/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-sink-connector.adoc
+++ b/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-sink-connector.adoc
@@ -2,11 +2,7 @@
 [[camel-jclouds-kafka-connector-sink]]
 = camel-jclouds-kafka-connector sink configuration
 
-<<<<<<< HEAD
-Connector Description: Interact with jclouds compute & blobstore service.
-=======
 Connector Description: Interact with jclouds compute and blobstore service.
->>>>>>> camel-master
 
 When using camel-jclouds-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
 
diff --git a/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-source-connector.adoc b/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-source-connector.adoc
index 7e89348..2e940df 100644
--- a/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-source-connector.adoc
+++ b/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-source-connector.adoc
@@ -2,11 +2,7 @@
 [[camel-jclouds-kafka-connector-source]]
 = camel-jclouds-kafka-connector source configuration
 
-<<<<<<< HEAD
-Connector description: Interact with jclouds compute & blobstore service.
-=======
 Connector description: Interact with jclouds compute and blobstore service.
->>>>>>> camel-master
 
 When using camel-jclouds-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:
 
diff --git a/connectors/camel-jsonata-kafka-connector/src/main/docs/camel-jsonata-kafka-sink-connector.adoc b/connectors/camel-jsonata-kafka-connector/src/main/docs/camel-jsonata-kafka-sink-connector.adoc
index 1e98beb..f181fff 100644
--- a/connectors/camel-jsonata-kafka-connector/src/main/docs/camel-jsonata-kafka-sink-connector.adoc
+++ b/connectors/camel-jsonata-kafka-connector/src/main/docs/camel-jsonata-kafka-sink-connector.adoc
@@ -2,11 +2,7 @@
 [[camel-jsonata-kafka-connector-sink]]
 = camel-jsonata-kafka-connector sink configuration
 
-<<<<<<< HEAD
-Connector Description: JSON to JSON transformation using JSONATA.
-=======
 Connector Description: Transforms JSON payload using JSONata transformation.
->>>>>>> camel-master
 
 When using camel-jsonata-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
 
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index ddb8488..ba70c20 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -170,12 +170,9 @@
 ** camel-azure-storage-blob-kafka-connector
 *** xref:connectors/camel-azure-storage-blob-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-azure-storage-blob-kafka-sink-connector.adoc[Sink Docs]
-<<<<<<< HEAD
-=======
 ** camel-azure-storage-datalake-kafka-connector
 *** xref:connectors/camel-azure-storage-datalake-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-azure-storage-datalake-kafka-sink-connector.adoc[Sink Docs]
->>>>>>> camel-master
 ** camel-azure-storage-queue-kafka-connector
 *** xref:connectors/camel-azure-storage-queue-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-azure-storage-queue-kafka-sink-connector.adoc[Sink Docs]
@@ -412,11 +409,8 @@
 *** xref:connectors/camel-http-kafka-sink-connector.adoc[Sink Docs]
 ** camel-https-kafka-connector
 *** xref:connectors/camel-https-kafka-sink-connector.adoc[Sink Docs]
-<<<<<<< HEAD
-=======
 ** camel-hwcloud-smn-kafka-connector
 *** xref:connectors/camel-hwcloud-smn-kafka-sink-connector.adoc[Sink Docs]
->>>>>>> camel-master
 ** camel-iec60870-client-kafka-connector
 *** xref:connectors/camel-iec60870-client-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-iec60870-client-kafka-sink-connector.adoc[Sink Docs]
@@ -445,12 +439,9 @@
 ** camel-imaps-kafka-connector
 *** xref:connectors/camel-imaps-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-imaps-kafka-sink-connector.adoc[Sink Docs]
-<<<<<<< HEAD
-=======
 ** camel-infinispan-embedded-kafka-connector
 *** xref:connectors/camel-infinispan-embedded-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-infinispan-embedded-kafka-sink-connector.adoc[Sink Docs]
->>>>>>> camel-master
 ** camel-infinispan-kafka-connector
 *** xref:connectors/camel-infinispan-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-infinispan-kafka-sink-connector.adoc[Sink Docs]
@@ -518,12 +509,9 @@
 ** camel-kafka-kafka-connector
 *** xref:connectors/camel-kafka-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-kafka-kafka-sink-connector.adoc[Sink Docs]
-<<<<<<< HEAD
-=======
 ** camel-kamelet-kafka-connector
 *** xref:connectors/camel-kamelet-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-kamelet-kafka-sink-connector.adoc[Sink Docs]
->>>>>>> camel-master
 ** camel-kubernetes-config-maps-kafka-connector
 *** xref:connectors/camel-kubernetes-config-maps-kafka-sink-connector.adoc[Sink Docs]
 ** camel-kubernetes-custom-resources-kafka-connector
@@ -667,12 +655,9 @@
 ** camel-paho-kafka-connector
 *** xref:connectors/camel-paho-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-paho-kafka-sink-connector.adoc[Sink Docs]
-<<<<<<< HEAD
-=======
 ** camel-paho-mqtt5-kafka-connector
 *** xref:connectors/camel-paho-mqtt5-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-paho-mqtt5-kafka-sink-connector.adoc[Sink Docs]
->>>>>>> camel-master
 ** camel-pdf-kafka-connector
 *** xref:connectors/camel-pdf-kafka-sink-connector.adoc[Sink Docs]
 ** camel-pg-replication-slot-kafka-connector
@@ -802,12 +787,9 @@
 *** xref:connectors/camel-spring-integration-kafka-sink-connector.adoc[Sink Docs]
 ** camel-spring-ldap-kafka-connector
 *** xref:connectors/camel-spring-ldap-kafka-sink-connector.adoc[Sink Docs]
-<<<<<<< HEAD
-=======
 ** camel-spring-rabbitmq-kafka-connector
 *** xref:connectors/camel-spring-rabbitmq-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-spring-rabbitmq-kafka-sink-connector.adoc[Sink Docs]
->>>>>>> camel-master
 ** camel-spring-redis-kafka-connector
 *** xref:connectors/camel-spring-redis-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-spring-redis-kafka-sink-connector.adoc[Sink Docs]
@@ -824,11 +806,8 @@
 *** xref:connectors/camel-ssh-kafka-sink-connector.adoc[Sink Docs]
 ** camel-stax-kafka-connector
 *** xref:connectors/camel-stax-kafka-sink-connector.adoc[Sink Docs]
-<<<<<<< HEAD
-=======
 ** camel-stitch-kafka-connector
 *** xref:connectors/camel-stitch-kafka-sink-connector.adoc[Sink Docs]
->>>>>>> camel-master
 ** camel-stomp-kafka-connector
 *** xref:connectors/camel-stomp-kafka-source-connector.adoc[Source Docs]
 *** xref:connectors/camel-stomp-kafka-sink-connector.adoc[Sink Docs]
diff --git a/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-sink-connector.adoc
index 11df96a..153358b 100644
--- a/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-sink-connector.adoc
@@ -2,11 +2,7 @@
 [[camel-jclouds-kafka-connector-sink]]
 = camel-jclouds-kafka-connector sink configuration
 
-<<<<<<< HEAD
-Connector Description: Interact with jclouds compute & blobstore service.
-=======
 Connector Description: Interact with jclouds compute and blobstore service.
->>>>>>> camel-master
 
 When using camel-jclouds-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
 
diff --git a/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-source-connector.adoc
index 7e89348..2e940df 100644
--- a/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-source-connector.adoc
@@ -2,11 +2,7 @@
 [[camel-jclouds-kafka-connector-source]]
 = camel-jclouds-kafka-connector source configuration
 
-<<<<<<< HEAD
-Connector description: Interact with jclouds compute & blobstore service.
-=======
 Connector description: Interact with jclouds compute and blobstore service.
->>>>>>> camel-master
 
 When using camel-jclouds-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:
 
diff --git a/docs/modules/ROOT/pages/connectors/camel-jsonata-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-jsonata-kafka-sink-connector.adoc
index 1e98beb..f181fff 100644
--- a/docs/modules/ROOT/pages/connectors/camel-jsonata-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-jsonata-kafka-sink-connector.adoc
@@ -2,11 +2,7 @@
 [[camel-jsonata-kafka-connector-sink]]
 = camel-jsonata-kafka-connector sink configuration
 
-<<<<<<< HEAD
-Connector Description: JSON to JSON transformation using JSONATA.
-=======
 Connector Description: Transforms JSON payload using JSONata transformation.
->>>>>>> camel-master
 
 When using camel-jsonata-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
 


[camel-kafka-connector] 01/02: Merge camel-master to master

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master-for-0.8.0
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 145a8afd41a8de8ef15884771026008c2673eca3
Merge: cc76192 698482d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Feb 16 13:32:06 2021 +0100

    Merge camel-master to master

 .../resources/connectors/camel-activemq-sink.json  |  13 +-
 .../connectors/camel-activemq-source.json          |  21 +-
 .../resources/connectors/camel-ahc-sink.json       |   7 -
 .../resources/connectors/camel-ahc-ws-sink.json    |   7 -
 .../resources/connectors/camel-ahc-ws-source.json  |   7 -
 .../resources/connectors/camel-ahc-wss-sink.json   |   7 -
 .../resources/connectors/camel-ahc-wss-source.json |   7 -
 .../resources/connectors/camel-amqp-sink.json      |  13 +-
 .../resources/connectors/camel-amqp-source.json    |  21 +-
 .../resources/connectors/camel-apns-sink.json      |   7 -
 .../resources/connectors/camel-apns-source.json    |   7 -
 .../resources/connectors/camel-arangodb-sink.json  |   7 -
 .../resources/connectors/camel-as2-sink.json       |   7 -
 .../resources/connectors/camel-as2-source.json     |   7 -
 .../resources/connectors/camel-asterisk-sink.json  |   7 -
 .../connectors/camel-asterisk-source.json          |   7 -
 .../resources/connectors/camel-atlasmap-sink.json  |   7 -
 .../resources/connectors/camel-atmos-sink.json     |   7 -
 .../resources/connectors/camel-atmos-source.json   |   7 -
 .../camel-atmosphere-websocket-sink.json           |   7 -
 .../camel-atmosphere-websocket-source.json         |   7 -
 .../resources/connectors/camel-atom-source.json    |   7 -
 .../connectors/camel-atomix-map-sink.json          |   7 -
 .../connectors/camel-atomix-map-source.json        |   7 -
 .../connectors/camel-atomix-messaging-sink.json    |   7 -
 .../connectors/camel-atomix-messaging-source.json  |   7 -
 .../connectors/camel-atomix-multimap-sink.json     |   7 -
 .../connectors/camel-atomix-queue-sink.json        |   7 -
 .../connectors/camel-atomix-queue-source.json      |   7 -
 .../connectors/camel-atomix-set-sink.json          |   7 -
 .../connectors/camel-atomix-set-source.json        |   7 -
 .../connectors/camel-atomix-value-sink.json        |   7 -
 .../connectors/camel-atomix-value-source.json      |   7 -
 .../resources/connectors/camel-avro-sink.json      |   7 -
 .../resources/connectors/camel-avro-source.json    |   7 -
 .../resources/connectors/camel-aws-cw-sink.json    |   7 -
 .../resources/connectors/camel-aws-ddb-sink.json   |   7 -
 .../connectors/camel-aws-ddbstream-source.json     |   7 -
 .../resources/connectors/camel-aws-ec2-sink.json   |   7 -
 .../resources/connectors/camel-aws-ecs-sink.json   |   7 -
 .../resources/connectors/camel-aws-eks-sink.json   |   7 -
 .../resources/connectors/camel-aws-iam-sink.json   |   7 -
 .../camel-aws-kinesis-firehose-sink.json           |   7 -
 .../connectors/camel-aws-kinesis-sink.json         |   7 -
 .../connectors/camel-aws-kinesis-source.json       |   7 -
 .../resources/connectors/camel-aws-kms-sink.json   |   7 -
 .../connectors/camel-aws-lambda-sink.json          |   7 -
 .../resources/connectors/camel-aws-mq-sink.json    |   7 -
 .../resources/connectors/camel-aws-msk-sink.json   |   7 -
 .../resources/connectors/camel-aws-s3-sink.json    |   7 -
 .../resources/connectors/camel-aws-s3-source.json  |  19 +-
 .../resources/connectors/camel-aws-sdb-sink.json   |   7 -
 .../resources/connectors/camel-aws-ses-sink.json   |   7 -
 .../resources/connectors/camel-aws-sns-sink.json   |   7 -
 .../resources/connectors/camel-aws-sqs-sink.json   |   7 -
 .../resources/connectors/camel-aws-sqs-source.json |   7 -
 .../resources/connectors/camel-aws-swf-sink.json   |   7 -
 .../resources/connectors/camel-aws-swf-source.json |   7 -
 .../connectors/camel-aws-translate-sink.json       |   7 -
 .../connectors/camel-aws2-athena-sink.json         |   7 -
 .../resources/connectors/camel-aws2-cw-sink.json   |   7 -
 .../resources/connectors/camel-aws2-ddb-sink.json  |   7 -
 .../connectors/camel-aws2-ddbstream-source.json    |   7 -
 .../resources/connectors/camel-aws2-ec2-sink.json  |   7 -
 .../resources/connectors/camel-aws2-ecs-sink.json  |   7 -
 .../resources/connectors/camel-aws2-eks-sink.json  |   7 -
 .../connectors/camel-aws2-eventbridge-sink.json    |   7 -
 .../resources/connectors/camel-aws2-iam-sink.json  |  19 +-
 .../camel-aws2-kinesis-firehose-sink.json          |  27 +-
 .../connectors/camel-aws2-kinesis-sink.json        |  33 +-
 .../connectors/camel-aws2-kinesis-source.json      |  33 +-
 .../resources/connectors/camel-aws2-kms-sink.json  |   7 -
 .../connectors/camel-aws2-lambda-sink.json         |   7 -
 .../resources/connectors/camel-aws2-mq-sink.json   |   7 -
 .../resources/connectors/camel-aws2-msk-sink.json  |   7 -
 .../resources/connectors/camel-aws2-s3-sink.json   |   7 -
 .../resources/connectors/camel-aws2-s3-source.json |  19 +-
 .../resources/connectors/camel-aws2-ses-sink.json  |   7 -
 .../resources/connectors/camel-aws2-sns-sink.json  |  11 +-
 .../resources/connectors/camel-aws2-sqs-sink.json  |  25 +-
 .../connectors/camel-aws2-sqs-source.json          |  11 +-
 .../resources/connectors/camel-aws2-sts-sink.json  |   7 -
 .../connectors/camel-aws2-translate-sink.json      |   7 -
 .../connectors/camel-azure-blob-sink.json          |   7 -
 .../connectors/camel-azure-blob-source.json        |   7 -
 .../connectors/camel-azure-eventhubs-sink.json     |   7 -
 .../connectors/camel-azure-eventhubs-source.json   |   7 -
 .../connectors/camel-azure-queue-sink.json         |   7 -
 .../connectors/camel-azure-queue-source.json       |   7 -
 .../connectors/camel-azure-storage-blob-sink.json  |   7 -
 .../camel-azure-storage-blob-source.json           |   7 -
 .../camel-azure-storage-datalake-sink.json         | 416 ++++++++++++++++++++
 .../camel-azure-storage-datalake-source.json       | 411 ++++++++++++++++++++
 .../connectors/camel-azure-storage-queue-sink.json |   7 -
 .../camel-azure-storage-queue-source.json          |   7 -
 .../resources/connectors/camel-bean-sink.json      |   7 -
 .../resources/connectors/camel-beanstalk-sink.json |   7 -
 .../connectors/camel-beanstalk-source.json         |   7 -
 .../resources/connectors/camel-box-sink.json       |   7 -
 .../resources/connectors/camel-box-source.json     |   7 -
 .../resources/connectors/camel-braintree-sink.json |   7 -
 .../connectors/camel-caffeine-cache-sink.json      |   7 -
 .../connectors/camel-caffeine-loadcache-sink.json  |   7 -
 .../connectors/camel-chatscript-sink.json          |   7 -
 .../resources/connectors/camel-chunk-sink.json     |   7 -
 .../resources/connectors/camel-cm-sms-sink.json    |   7 -
 .../resources/connectors/camel-cmis-sink.json      |   7 -
 .../resources/connectors/camel-cmis-source.json    |   7 -
 .../resources/connectors/camel-coap+tcp-sink.json  |   7 -
 .../connectors/camel-coap+tcp-source.json          |   7 -
 .../resources/connectors/camel-coap-sink.json      |   7 -
 .../resources/connectors/camel-coap-source.json    |   7 -
 .../resources/connectors/camel-coaps+tcp-sink.json |   7 -
 .../connectors/camel-coaps+tcp-source.json         |   7 -
 .../resources/connectors/camel-coaps-sink.json     |   7 -
 .../resources/connectors/camel-coaps-source.json   |   7 -
 .../resources/connectors/camel-cometd-sink.json    |   7 -
 .../resources/connectors/camel-cometd-source.json  |   7 -
 .../resources/connectors/camel-cometds-sink.json   |   7 -
 .../resources/connectors/camel-cometds-source.json |   7 -
 .../resources/connectors/camel-consul-sink.json    |   7 -
 .../resources/connectors/camel-consul-source.json  |   7 -
 .../connectors/camel-controlbus-sink.json          |   7 -
 .../resources/connectors/camel-corda-sink.json     |   7 -
 .../resources/connectors/camel-corda-source.json   |   7 -
 .../resources/connectors/camel-couchbase-sink.json |   7 -
 .../connectors/camel-couchbase-source.json         |   7 -
 .../resources/connectors/camel-couchdb-sink.json   |   7 -
 .../resources/connectors/camel-couchdb-source.json |   7 -
 .../resources/connectors/camel-cql-sink.json       |   7 -
 .../resources/connectors/camel-cql-source.json     |   7 -
 .../resources/connectors/camel-cron-source.json    |   7 -
 .../connectors/camel-crypto-cms-sink.json          |   7 -
 .../resources/connectors/camel-crypto-sink.json    |   7 -
 .../resources/connectors/camel-cxf-sink.json       |  14 +-
 .../resources/connectors/camel-cxf-source.json     |   7 -
 .../resources/connectors/camel-cxfrs-sink.json     |  14 +-
 .../resources/connectors/camel-cxfrs-source.json   |   7 -
 .../connectors/camel-dataformat-sink.json          |   7 -
 .../resources/connectors/camel-direct-sink.json    |   2 +-
 .../resources/connectors/camel-direct-source.json  |   2 +-
 .../resources/connectors/camel-direct-vm-sink.json |   7 -
 .../connectors/camel-direct-vm-source.json         |   7 -
 .../resources/connectors/camel-disruptor-sink.json |   7 -
 .../connectors/camel-disruptor-source.json         |   7 -
 .../connectors/camel-disruptor-vm-sink.json        |   7 -
 .../connectors/camel-disruptor-vm-source.json      |   7 -
 .../resources/connectors/camel-djl-sink.json       |   7 -
 .../resources/connectors/camel-dns-sink.json       |   7 -
 .../resources/connectors/camel-docker-sink.json    |   7 -
 .../resources/connectors/camel-docker-source.json  |   7 -
 .../resources/connectors/camel-dozer-sink.json     |   7 -
 .../resources/connectors/camel-drill-sink.json     |   7 -
 .../resources/connectors/camel-dropbox-sink.json   |   7 -
 .../resources/connectors/camel-dropbox-source.json |   7 -
 .../resources/connectors/camel-ehcache-sink.json   |   7 -
 .../resources/connectors/camel-ehcache-source.json |   7 -
 .../connectors/camel-elasticsearch-rest-sink.json  |   7 -
 .../resources/connectors/camel-elsql-sink.json     |   7 -
 .../resources/connectors/camel-elsql-source.json   |   7 -
 .../resources/connectors/camel-etcd-keys-sink.json |   7 -
 .../connectors/camel-etcd-stats-sink.json          |   7 -
 .../connectors/camel-etcd-stats-source.json        |   7 -
 .../connectors/camel-etcd-watch-source.json        |   7 -
 .../resources/connectors/camel-exec-sink.json      |   7 -
 .../resources/connectors/camel-facebook-sink.json  |   7 -
 .../connectors/camel-facebook-source.json          |   7 -
 .../resources/connectors/camel-fhir-sink.json      |   7 -
 .../resources/connectors/camel-fhir-source.json    |   7 -
 .../resources/connectors/camel-file-sink.json      |   2 +-
 .../resources/connectors/camel-file-source.json    |  14 +-
 .../connectors/camel-file-watch-source.json        |   7 -
 .../resources/connectors/camel-flatpack-sink.json  |   7 -
 .../connectors/camel-flatpack-source.json          |   7 -
 .../resources/connectors/camel-flink-sink.json     |   7 -
 .../resources/connectors/camel-fop-sink.json       |   7 -
 .../connectors/camel-freemarker-sink.json          |   7 -
 .../resources/connectors/camel-ftp-sink.json       |   2 +-
 .../resources/connectors/camel-ftp-source.json     |  14 +-
 .../resources/connectors/camel-ftps-sink.json      |   2 +-
 .../resources/connectors/camel-ftps-source.json    |  14 +-
 .../resources/connectors/camel-ganglia-sink.json   |   7 -
 .../resources/connectors/camel-geocoder-sink.json  |   7 -
 .../resources/connectors/camel-git-sink.json       |   7 -
 .../resources/connectors/camel-git-source.json     |   7 -
 .../resources/connectors/camel-github-sink.json    |   7 -
 .../resources/connectors/camel-github-source.json  |   7 -
 .../connectors/camel-google-bigquery-sink.json     |   7 -
 .../connectors/camel-google-bigquery-sql-sink.json |   7 -
 .../connectors/camel-google-calendar-sink.json     |  79 ++--
 .../connectors/camel-google-calendar-source.json   |  79 ++--
 .../camel-google-calendar-stream-source.json       |  57 ++-
 .../connectors/camel-google-drive-sink.json        |   7 -
 .../connectors/camel-google-drive-source.json      |   7 -
 .../connectors/camel-google-mail-sink.json         |   7 -
 .../connectors/camel-google-mail-source.json       |   7 -
 .../camel-google-mail-stream-source.json           |   7 -
 .../connectors/camel-google-pubsub-sink.json       |  20 +-
 .../connectors/camel-google-pubsub-source.json     |   7 -
 .../connectors/camel-google-sheets-sink.json       |   7 -
 .../connectors/camel-google-sheets-source.json     |   7 -
 .../camel-google-sheets-stream-source.json         |   7 -
 .../resources/connectors/camel-gora-sink.json      |   7 -
 .../resources/connectors/camel-gora-source.json    |   7 -
 .../resources/connectors/camel-grape-sink.json     |   7 -
 .../resources/connectors/camel-graphql-sink.json   |   7 -
 .../resources/connectors/camel-grpc-sink.json      |   2 +-
 .../resources/connectors/camel-grpc-source.json    |   2 +-
 .../connectors/camel-guava-eventbus-sink.json      |   7 -
 .../connectors/camel-guava-eventbus-source.json    |   7 -
 .../camel-hazelcast-atomicvalue-sink.json          |   7 -
 .../camel-hazelcast-instance-source.json           |   7 -
 .../connectors/camel-hazelcast-list-sink.json      |   7 -
 .../connectors/camel-hazelcast-list-source.json    |   7 -
 .../connectors/camel-hazelcast-map-sink.json       |   7 -
 .../connectors/camel-hazelcast-map-source.json     |   7 -
 .../connectors/camel-hazelcast-multimap-sink.json  |   7 -
 .../camel-hazelcast-multimap-source.json           |   7 -
 .../connectors/camel-hazelcast-queue-sink.json     |   7 -
 .../connectors/camel-hazelcast-queue-source.json   |   7 -
 .../camel-hazelcast-replicatedmap-sink.json        |   7 -
 .../camel-hazelcast-replicatedmap-source.json      |   7 -
 .../camel-hazelcast-ringbuffer-sink.json           |   7 -
 .../connectors/camel-hazelcast-seda-sink.json      |   7 -
 .../connectors/camel-hazelcast-seda-source.json    |   7 -
 .../connectors/camel-hazelcast-set-sink.json       |   7 -
 .../connectors/camel-hazelcast-set-source.json     |   7 -
 .../connectors/camel-hazelcast-topic-sink.json     |   7 -
 .../connectors/camel-hazelcast-topic-source.json   |   7 -
 .../resources/connectors/camel-hbase-sink.json     |   7 -
 .../resources/connectors/camel-hbase-source.json   |   7 -
 .../resources/connectors/camel-hdfs-sink.json      |   7 -
 .../resources/connectors/camel-hdfs-source.json    |   7 -
 .../resources/connectors/camel-http-sink.json      |   7 -
 .../resources/connectors/camel-https-sink.json     |   7 -
 .../connectors/camel-hwcloud-smn-sink.json         | 114 ++++++
 .../connectors/camel-iec60870-client-sink.json     |   7 -
 .../connectors/camel-iec60870-client-source.json   |   7 -
 .../connectors/camel-iec60870-server-sink.json     |   7 -
 .../connectors/camel-iec60870-server-source.json   |   7 -
 .../connectors/camel-ignite-cache-sink.json        |   7 -
 .../connectors/camel-ignite-cache-source.json      |   7 -
 .../connectors/camel-ignite-compute-sink.json      |   7 -
 .../connectors/camel-ignite-events-source.json     |   7 -
 .../connectors/camel-ignite-idgen-sink.json        |   7 -
 .../connectors/camel-ignite-messaging-sink.json    |   7 -
 .../connectors/camel-ignite-messaging-source.json  |   7 -
 .../connectors/camel-ignite-queue-sink.json        |   7 -
 .../connectors/camel-ignite-set-sink.json          |   7 -
 .../resources/connectors/camel-imap-sink.json      |   7 -
 .../resources/connectors/camel-imap-source.json    |  21 +-
 .../resources/connectors/camel-imaps-sink.json     |   7 -
 .../resources/connectors/camel-imaps-source.json   |  21 +-
 .../connectors/camel-infinispan-embedded-sink.json | 238 ++++++++++++
 .../camel-infinispan-embedded-source.json          | 199 ++++++++++
 .../connectors/camel-infinispan-sink.json          |  23 +-
 .../connectors/camel-infinispan-source.json        |  65 +---
 .../resources/connectors/camel-influxdb-sink.json  |   7 -
 .../resources/connectors/camel-iota-sink.json      |   7 -
 .../resources/connectors/camel-ipfs-sink.json      |   7 -
 .../resources/connectors/camel-irc-sink.json       |   7 -
 .../resources/connectors/camel-irc-source.json     |   7 -
 .../resources/connectors/camel-ironmq-sink.json    |   7 -
 .../resources/connectors/camel-ironmq-source.json  |   7 -
 .../resources/connectors/camel-jbpm-sink.json      |   7 -
 .../resources/connectors/camel-jbpm-source.json    |  14 +-
 .../resources/connectors/camel-jclouds-sink.json   |   9 +-
 .../resources/connectors/camel-jclouds-source.json |   9 +-
 .../resources/connectors/camel-jcr-sink.json       |   7 -
 .../resources/connectors/camel-jcr-source.json     |   7 -
 .../resources/connectors/camel-jdbc-sink.json      |   7 -
 .../resources/connectors/camel-jetty-source.json   |   7 -
 .../connectors/camel-jgroups-raft-sink.json        |   7 -
 .../connectors/camel-jgroups-raft-source.json      |   7 -
 .../resources/connectors/camel-jgroups-sink.json   |   7 -
 .../resources/connectors/camel-jgroups-source.json |   7 -
 .../resources/connectors/camel-jing-sink.json      |   7 -
 .../resources/connectors/camel-jira-sink.json      |   7 -
 .../resources/connectors/camel-jira-source.json    |   7 -
 .../resources/connectors/camel-jms-sink.json       |  13 +-
 .../resources/connectors/camel-jms-source.json     |  21 +-
 .../resources/connectors/camel-jmx-source.json     |   7 -
 .../resources/connectors/camel-jolt-sink.json      |   7 -
 .../resources/connectors/camel-jooq-sink.json      |   7 -
 .../resources/connectors/camel-jooq-source.json    |   7 -
 .../resources/connectors/camel-jpa-sink.json       |   7 -
 .../resources/connectors/camel-jpa-source.json     |   7 -
 .../resources/connectors/camel-jslt-sink.json      |  24 +-
 .../connectors/camel-json-validator-sink.json      |   7 -
 .../resources/connectors/camel-jsonata-sink.json   |  11 +-
 .../resources/connectors/camel-jt400-sink.json     |   7 -
 .../resources/connectors/camel-jt400-source.json   |   7 -
 .../resources/connectors/camel-kafka-sink.json     |  15 +-
 .../resources/connectors/camel-kafka-source.json   |  15 +-
 .../resources/connectors/camel-kamelet-sink.json   |  93 +++++
 .../resources/connectors/camel-kamelet-source.json |  75 ++++
 .../camel-kubernetes-config-maps-sink.json         |   7 -
 .../camel-kubernetes-custom-resources-sink.json    |   7 -
 .../camel-kubernetes-custom-resources-source.json  |   7 -
 .../camel-kubernetes-deployments-sink.json         |   7 -
 .../camel-kubernetes-deployments-source.json       |   7 -
 .../connectors/camel-kubernetes-hpa-sink.json      |   7 -
 .../connectors/camel-kubernetes-hpa-source.json    |   7 -
 .../connectors/camel-kubernetes-job-sink.json      |   7 -
 .../connectors/camel-kubernetes-job-source.json    |   7 -
 .../camel-kubernetes-namespaces-sink.json          |   7 -
 .../camel-kubernetes-namespaces-source.json        |   7 -
 .../connectors/camel-kubernetes-nodes-sink.json    |   7 -
 .../connectors/camel-kubernetes-nodes-source.json  |   7 -
 ...-kubernetes-persistent-volumes-claims-sink.json |   7 -
 .../camel-kubernetes-persistent-volumes-sink.json  |   7 -
 .../connectors/camel-kubernetes-pods-sink.json     |   7 -
 .../connectors/camel-kubernetes-pods-source.json   |   7 -
 ...el-kubernetes-replication-controllers-sink.json |   7 -
 ...-kubernetes-replication-controllers-source.json |   7 -
 .../camel-kubernetes-resources-quota-sink.json     |   7 -
 .../connectors/camel-kubernetes-secrets-sink.json  |   7 -
 .../camel-kubernetes-service-accounts-sink.json    |   7 -
 .../connectors/camel-kubernetes-services-sink.json |   7 -
 .../camel-kubernetes-services-source.json          |   7 -
 .../resources/connectors/camel-kudu-sink.json      |   7 -
 .../resources/connectors/camel-language-sink.json  |   7 -
 .../resources/connectors/camel-ldap-sink.json      |   7 -
 .../resources/connectors/camel-ldif-sink.json      |   7 -
 .../resources/connectors/camel-log-sink.json       |   7 -
 .../resources/connectors/camel-lpr-sink.json       |   7 -
 .../resources/connectors/camel-lucene-sink.json    |   7 -
 .../connectors/camel-lumberjack-source.json        |   7 -
 .../resources/connectors/camel-master-source.json  |   7 -
 .../resources/connectors/camel-metrics-sink.json   |   7 -
 .../connectors/camel-micrometer-sink.json          |   7 -
 .../camel-microprofile-metrics-sink.json           |   7 -
 .../connectors/camel-milo-client-sink.json         |  47 ++-
 .../connectors/camel-milo-client-source.json       |  47 ++-
 .../connectors/camel-milo-server-sink.json         |   7 -
 .../connectors/camel-milo-server-source.json       |   7 -
 .../resources/connectors/camel-mina-sink.json      |   7 -
 .../resources/connectors/camel-mina-source.json    |   7 -
 .../resources/connectors/camel-minio-sink.json     |   7 -
 .../resources/connectors/camel-minio-source.json   |   7 -
 .../resources/connectors/camel-mllp-sink.json      |   7 -
 .../resources/connectors/camel-mllp-source.json    |   7 -
 .../connectors/camel-mongodb-gridfs-sink.json      |   7 -
 .../connectors/camel-mongodb-gridfs-source.json    |   7 -
 .../resources/connectors/camel-mongodb-sink.json   |   7 -
 .../resources/connectors/camel-mongodb-source.json |   7 -
 .../resources/connectors/camel-msv-sink.json       |   7 -
 .../resources/connectors/camel-mustache-sink.json  |   7 -
 .../resources/connectors/camel-mvel-sink.json      |   7 -
 .../connectors/camel-mybatis-bean-sink.json        |   7 -
 .../resources/connectors/camel-mybatis-sink.json   |   7 -
 .../resources/connectors/camel-mybatis-source.json |   7 -
 .../resources/connectors/camel-nagios-sink.json    |   7 -
 .../resources/connectors/camel-nats-sink.json      |  14 +-
 .../resources/connectors/camel-nats-source.json    |   7 -
 .../connectors/camel-netty-http-sink.json          |   2 +-
 .../connectors/camel-netty-http-source.json        |   2 +-
 .../resources/connectors/camel-netty-sink.json     |   2 +-
 .../resources/connectors/camel-netty-source.json   |   2 +-
 .../resources/connectors/camel-nitrite-sink.json   |   7 -
 .../resources/connectors/camel-nitrite-source.json |   7 -
 .../resources/connectors/camel-nsq-sink.json       |   7 -
 .../resources/connectors/camel-nsq-source.json     |   7 -
 .../resources/connectors/camel-oaipmh-sink.json    |   7 -
 .../resources/connectors/camel-oaipmh-source.json  |   7 -
 .../resources/connectors/camel-olingo2-sink.json   |   7 -
 .../resources/connectors/camel-olingo2-source.json |   7 -
 .../resources/connectors/camel-olingo4-sink.json   |   7 -
 .../resources/connectors/camel-olingo4-source.json |   7 -
 .../camel-openshift-build-configs-sink.json        |   7 -
 .../connectors/camel-openshift-builds-sink.json    |   7 -
 .../connectors/camel-openstack-cinder-sink.json    |   7 -
 .../connectors/camel-openstack-glance-sink.json    |   7 -
 .../connectors/camel-openstack-keystone-sink.json  |   7 -
 .../connectors/camel-openstack-neutron-sink.json   |   7 -
 .../connectors/camel-openstack-nova-sink.json      |   7 -
 .../connectors/camel-openstack-swift-sink.json     |   7 -
 .../connectors/camel-optaplanner-sink.json         |   7 -
 .../connectors/camel-optaplanner-source.json       |   7 -
 .../connectors/camel-paho-mqtt5-sink.json          | 406 ++++++++++++++++++++
 .../connectors/camel-paho-mqtt5-source.json        | 423 +++++++++++++++++++++
 .../resources/connectors/camel-paho-sink.json      |   7 -
 .../resources/connectors/camel-paho-source.json    |   7 -
 .../resources/connectors/camel-pdf-sink.json       |   7 -
 .../camel-pg-replication-slot-source.json          |   7 -
 .../resources/connectors/camel-pgevent-sink.json   |   7 -
 .../resources/connectors/camel-pgevent-source.json |   7 -
 .../connectors/camel-platform-http-source.json     |   7 -
 .../resources/connectors/camel-pop3-sink.json      |   7 -
 .../resources/connectors/camel-pop3-source.json    |  21 +-
 .../resources/connectors/camel-pop3s-sink.json     |   7 -
 .../resources/connectors/camel-pop3s-source.json   |  21 +-
 .../resources/connectors/camel-pubnub-sink.json    |   7 -
 .../resources/connectors/camel-pubnub-source.json  |   7 -
 .../resources/connectors/camel-pulsar-sink.json    |   7 -
 .../resources/connectors/camel-pulsar-source.json  |   7 -
 .../resources/connectors/camel-quartz-source.json  |   7 -
 .../resources/connectors/camel-quickfix-sink.json  |   7 -
 .../connectors/camel-quickfix-source.json          |   7 -
 .../resources/connectors/camel-rabbitmq-sink.json  |  21 +-
 .../connectors/camel-rabbitmq-source.json          |  21 +-
 .../connectors/camel-reactive-streams-sink.json    |   7 -
 .../connectors/camel-reactive-streams-source.json  |   7 -
 .../connectors/camel-rest-api-source.json          |   7 -
 .../connectors/camel-rest-openapi-sink.json        |   7 -
 .../resources/connectors/camel-rest-sink.json      |   7 -
 .../resources/connectors/camel-rest-source.json    |   7 -
 .../connectors/camel-rest-swagger-sink.json        |   7 -
 .../resources/connectors/camel-resteasy-sink.json  |   7 -
 .../connectors/camel-resteasy-source.json          |   7 -
 .../resources/connectors/camel-rss-source.json     |   7 -
 .../resources/connectors/camel-saga-sink.json      |   7 -
 .../connectors/camel-salesforce-sink.json          |  87 ++++-
 .../connectors/camel-salesforce-source.json        |  67 +++-
 .../connectors/camel-sap-netweaver-sink.json       |   7 -
 .../connectors/camel-scheduler-source.json         |   2 +-
 .../connectors/camel-schematron-sink.json          |   7 -
 .../resources/connectors/camel-scp-sink.json       |   2 +-
 .../resources/connectors/camel-seda-sink.json      |   7 -
 .../resources/connectors/camel-seda-source.json    |   7 -
 .../resources/connectors/camel-service-source.json |   7 -
 .../connectors/camel-servicenow-sink.json          |   7 -
 .../resources/connectors/camel-servlet-source.json |   7 -
 .../resources/connectors/camel-sftp-sink.json      |   2 +-
 .../resources/connectors/camel-sftp-source.json    |  14 +-
 .../resources/connectors/camel-sip-sink.json       |   7 -
 .../resources/connectors/camel-sip-source.json     |   9 +-
 .../resources/connectors/camel-sips-sink.json      |   7 -
 .../resources/connectors/camel-sips-source.json    |   9 +-
 .../resources/connectors/camel-sjms-sink.json      | 231 ++++++-----
 .../resources/connectors/camel-sjms-source.json    | 247 +++++-------
 .../resources/connectors/camel-sjms2-sink.json     | 231 ++++++-----
 .../resources/connectors/camel-sjms2-source.json   | 251 +++++-------
 .../resources/connectors/camel-slack-sink.json     |   7 -
 .../resources/connectors/camel-slack-source.json   |   7 -
 .../resources/connectors/camel-smpp-sink.json      |   7 -
 .../resources/connectors/camel-smpp-source.json    |   7 -
 .../resources/connectors/camel-smpps-sink.json     |   7 -
 .../resources/connectors/camel-smpps-source.json   |   7 -
 .../resources/connectors/camel-smtp-sink.json      |   7 -
 .../resources/connectors/camel-smtp-source.json    |  21 +-
 .../resources/connectors/camel-smtps-sink.json     |   7 -
 .../resources/connectors/camel-smtps-source.json   |  21 +-
 .../resources/connectors/camel-snmp-sink.json      |   7 -
 .../resources/connectors/camel-snmp-source.json    |   7 -
 .../resources/connectors/camel-solr-sink.json      |   7 -
 .../resources/connectors/camel-solrCloud-sink.json |   7 -
 .../resources/connectors/camel-solrs-sink.json     |   7 -
 .../resources/connectors/camel-soroush-sink.json   |   7 -
 .../resources/connectors/camel-soroush-source.json |   7 -
 .../resources/connectors/camel-spark-sink.json     |   7 -
 .../connectors/camel-splunk-hec-sink.json          |   7 -
 .../resources/connectors/camel-splunk-sink.json    |   7 -
 .../resources/connectors/camel-splunk-source.json  |   7 -
 .../connectors/camel-spring-batch-sink.json        |   7 -
 .../connectors/camel-spring-event-sink.json        |   7 -
 .../connectors/camel-spring-event-source.json      |   7 -
 .../connectors/camel-spring-integration-sink.json  |   7 -
 .../camel-spring-integration-source.json           |   7 -
 .../connectors/camel-spring-ldap-sink.json         |   7 -
 .../connectors/camel-spring-rabbitmq-sink.json     | 149 ++++++++
 .../connectors/camel-spring-rabbitmq-source.json   | 319 ++++++++++++++++
 .../connectors/camel-spring-redis-sink.json        |   7 +-
 .../connectors/camel-spring-redis-source.json      |   7 +-
 .../resources/connectors/camel-spring-ws-sink.json |   7 -
 .../connectors/camel-spring-ws-source.json         |   7 -
 .../resources/connectors/camel-sql-sink.json       |   9 +-
 .../resources/connectors/camel-sql-source.json     |   9 +-
 .../connectors/camel-sql-stored-sink.json          |   7 -
 .../resources/connectors/camel-ssh-sink.json       |   7 -
 .../resources/connectors/camel-ssh-source.json     |   7 -
 .../resources/connectors/camel-stax-sink.json      |   7 -
 .../resources/connectors/camel-stitch-sink.json    | 140 +++++++
 .../resources/connectors/camel-stomp-sink.json     |   7 -
 .../resources/connectors/camel-stomp-source.json   |   7 -
 .../resources/connectors/camel-stream-sink.json    |   7 -
 .../resources/connectors/camel-stream-source.json  |   7 -
 .../connectors/camel-string-template-sink.json     |   7 -
 .../resources/connectors/camel-stub-sink.json      |   7 -
 .../resources/connectors/camel-stub-source.json    |   7 -
 .../resources/connectors/camel-telegram-sink.json  |   7 -
 .../connectors/camel-telegram-source.json          |   7 -
 .../resources/connectors/camel-thrift-sink.json    |   2 +-
 .../resources/connectors/camel-thrift-source.json  |   2 +-
 .../resources/connectors/camel-tika-sink.json      |   7 -
 .../resources/connectors/camel-timer-source.json   |   2 +-
 .../resources/connectors/camel-twilio-sink.json    |   7 -
 .../resources/connectors/camel-twilio-source.json  |   7 -
 .../camel-twitter-directmessage-sink.json          |   7 -
 .../camel-twitter-directmessage-source.json        |   7 -
 .../connectors/camel-twitter-search-sink.json      |   7 -
 .../connectors/camel-twitter-search-source.json    |   7 -
 .../connectors/camel-twitter-timeline-sink.json    |   7 -
 .../connectors/camel-twitter-timeline-source.json  |   7 -
 .../resources/connectors/camel-undertow-sink.json  |   7 -
 .../connectors/camel-undertow-source.json          |   7 -
 .../resources/connectors/camel-validator-sink.json |   7 -
 .../resources/connectors/camel-velocity-sink.json  |   7 -
 .../connectors/camel-vertx-http-sink.json          |   7 -
 .../connectors/camel-vertx-kafka-sink.json         | 107 +++++-
 .../connectors/camel-vertx-kafka-source.json       |  99 ++++-
 .../resources/connectors/camel-vertx-sink.json     |   7 -
 .../resources/connectors/camel-vertx-source.json   |   7 -
 .../connectors/camel-vertx-websocket-sink.json     |   7 -
 .../connectors/camel-vertx-websocket-source.json   |   7 -
 .../resources/connectors/camel-vm-sink.json        |   7 -
 .../resources/connectors/camel-vm-source.json      |   7 -
 .../resources/connectors/camel-weather-sink.json   |   7 -
 .../resources/connectors/camel-weather-source.json |   7 -
 .../resources/connectors/camel-web3j-sink.json     |   7 -
 .../resources/connectors/camel-web3j-source.json   |   7 -
 .../resources/connectors/camel-webhook-source.json |   7 -
 .../connectors/camel-websocket-jsr356-sink.json    |   7 -
 .../connectors/camel-websocket-jsr356-source.json  |   7 -
 .../resources/connectors/camel-websocket-sink.json |   7 -
 .../connectors/camel-websocket-source.json         |   7 -
 .../resources/connectors/camel-weka-sink.json      |   7 -
 .../resources/connectors/camel-wordpress-sink.json |   7 -
 .../connectors/camel-wordpress-source.json         |   7 -
 .../resources/connectors/camel-workday-sink.json   |   7 -
 .../resources/connectors/camel-xchange-sink.json   |   7 -
 .../resources/connectors/camel-xj-sink.json        |   7 -
 .../connectors/camel-xmlsecurity-sign-sink.json    |   7 -
 .../connectors/camel-xmlsecurity-verify-sink.json  |   7 -
 .../resources/connectors/camel-xmpp-sink.json      |   7 -
 .../resources/connectors/camel-xmpp-source.json    |   7 -
 .../resources/connectors/camel-xquery-sink.json    |   7 -
 .../resources/connectors/camel-xquery-source.json  |   7 -
 .../connectors/camel-xslt-saxon-sink.json          |   7 -
 .../resources/connectors/camel-xslt-sink.json      |   7 -
 .../resources/connectors/camel-yammer-sink.json    |   7 -
 .../resources/connectors/camel-yammer-source.json  |   7 -
 .../resources/connectors/camel-zendesk-sink.json   |   7 -
 .../resources/connectors/camel-zendesk-source.json |   7 -
 .../connectors/camel-zookeeper-master-source.json  |   7 -
 .../resources/connectors/camel-zookeeper-sink.json |   7 -
 .../connectors/camel-zookeeper-source.json         |   7 -
 .../resources/descriptors/connectors.properties    |  12 +
 .../generated/resources/camel-activemq-sink.json   |  13 +-
 .../generated/resources/camel-activemq-source.json |  21 +-
 .../docs/camel-activemq-kafka-sink-connector.adoc  |   9 +-
 .../camel-activemq-kafka-source-connector.adoc     |   7 +-
 .../activemq/CamelActivemqSinkConnectorConfig.java |  10 +-
 .../CamelActivemqSourceConnectorConfig.java        |  14 +-
 .../src/generated/resources/camel-ahc-sink.json    |   7 -
 .../main/docs/camel-ahc-kafka-sink-connector.adoc  |   3 +-
 .../ahc/CamelAhcSinkConnectorConfig.java           |   4 -
 .../src/generated/resources/camel-ahc-ws-sink.json |   7 -
 .../generated/resources/camel-ahc-ws-source.json   |   7 -
 .../docs/camel-ahc-ws-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-ahc-ws-kafka-source-connector.adoc  |   3 +-
 .../ahcws/CamelAhcwsSinkConnectorConfig.java       |   4 -
 .../ahcws/CamelAhcwsSourceConnectorConfig.java     |   4 -
 .../generated/resources/camel-ahc-wss-sink.json    |   7 -
 .../generated/resources/camel-ahc-wss-source.json  |   7 -
 .../docs/camel-ahc-wss-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-ahc-wss-kafka-source-connector.adoc |   3 +-
 .../ahcwss/CamelAhcwssSinkConnectorConfig.java     |   4 -
 .../ahcwss/CamelAhcwssSourceConnectorConfig.java   |   4 -
 .../src/generated/resources/camel-amqp-sink.json   |  13 +-
 .../src/generated/resources/camel-amqp-source.json |  21 +-
 .../main/docs/camel-amqp-kafka-sink-connector.adoc |   9 +-
 .../docs/camel-amqp-kafka-source-connector.adoc    |   7 +-
 .../amqp/CamelAmqpSinkConnectorConfig.java         |  10 +-
 .../amqp/CamelAmqpSourceConnectorConfig.java       |  14 +-
 .../src/generated/resources/camel-apns-sink.json   |   7 -
 .../src/generated/resources/camel-apns-source.json |   7 -
 .../main/docs/camel-apns-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-apns-kafka-source-connector.adoc    |   3 +-
 .../apns/CamelApnsSinkConnectorConfig.java         |   4 -
 .../apns/CamelApnsSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-arangodb-sink.json   |   7 -
 .../docs/camel-arangodb-kafka-sink-connector.adoc  |   3 +-
 .../arangodb/CamelArangodbSinkConnectorConfig.java |   4 -
 .../src/generated/resources/camel-as2-sink.json    |   7 -
 .../src/generated/resources/camel-as2-source.json  |   7 -
 .../main/docs/camel-as2-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-as2-kafka-source-connector.adoc     |   3 +-
 .../as2/CamelAs2SinkConnectorConfig.java           |   4 -
 .../as2/CamelAs2SourceConnectorConfig.java         |   4 -
 .../generated/resources/camel-asterisk-sink.json   |   7 -
 .../generated/resources/camel-asterisk-source.json |   7 -
 .../docs/camel-asterisk-kafka-sink-connector.adoc  |   3 +-
 .../camel-asterisk-kafka-source-connector.adoc     |   3 +-
 .../asterisk/CamelAsteriskSinkConnectorConfig.java |   4 -
 .../CamelAsteriskSourceConnectorConfig.java        |   4 -
 .../generated/resources/camel-atlasmap-sink.json   |   7 -
 .../docs/camel-atlasmap-kafka-sink-connector.adoc  |   3 +-
 .../atlasmap/CamelAtlasmapSinkConnectorConfig.java |   4 -
 .../src/generated/resources/camel-atmos-sink.json  |   7 -
 .../generated/resources/camel-atmos-source.json    |   7 -
 .../docs/camel-atmos-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-atmos-kafka-source-connector.adoc   |   3 +-
 .../atmos/CamelAtmosSinkConnectorConfig.java       |   4 -
 .../atmos/CamelAtmosSourceConnectorConfig.java     |   4 -
 .../resources/camel-atmosphere-websocket-sink.json |   7 -
 .../camel-atmosphere-websocket-source.json         |   7 -
 ...-atmosphere-websocket-kafka-sink-connector.adoc |   3 +-
 ...tmosphere-websocket-kafka-source-connector.adoc |   3 +-
 ...amelAtmospherewebsocketSinkConnectorConfig.java |   4 -
 ...elAtmospherewebsocketSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-atom-source.json |   7 -
 .../docs/camel-atom-kafka-source-connector.adoc    |   3 +-
 .../atom/CamelAtomSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-atomix-map-sink.json |   7 -
 .../resources/camel-atomix-map-source.json         |   7 -
 .../camel-atomix-map-kafka-sink-connector.adoc     |   3 +-
 .../camel-atomix-map-kafka-source-connector.adoc   |   3 +-
 .../CamelAtomixmapSinkConnectorConfig.java         |   4 -
 .../CamelAtomixmapSourceConnectorConfig.java       |   4 -
 .../resources/camel-atomix-messaging-sink.json     |   7 -
 .../resources/camel-atomix-messaging-source.json   |   7 -
 ...amel-atomix-messaging-kafka-sink-connector.adoc |   3 +-
 ...el-atomix-messaging-kafka-source-connector.adoc |   3 +-
 .../CamelAtomixmessagingSinkConnectorConfig.java   |   4 -
 .../CamelAtomixmessagingSourceConnectorConfig.java |   4 -
 .../resources/camel-atomix-multimap-sink.json      |   7 -
 ...camel-atomix-multimap-kafka-sink-connector.adoc |   3 +-
 .../CamelAtomixmultimapSinkConnectorConfig.java    |   4 -
 .../resources/camel-atomix-queue-sink.json         |   7 -
 .../resources/camel-atomix-queue-source.json       |   7 -
 .../camel-atomix-queue-kafka-sink-connector.adoc   |   3 +-
 .../camel-atomix-queue-kafka-source-connector.adoc |   3 +-
 .../CamelAtomixqueueSinkConnectorConfig.java       |   4 -
 .../CamelAtomixqueueSourceConnectorConfig.java     |   4 -
 .../generated/resources/camel-atomix-set-sink.json |   7 -
 .../resources/camel-atomix-set-source.json         |   7 -
 .../camel-atomix-set-kafka-sink-connector.adoc     |   3 +-
 .../camel-atomix-set-kafka-source-connector.adoc   |   3 +-
 .../CamelAtomixsetSinkConnectorConfig.java         |   4 -
 .../CamelAtomixsetSourceConnectorConfig.java       |   4 -
 .../resources/camel-atomix-value-sink.json         |   7 -
 .../resources/camel-atomix-value-source.json       |   7 -
 .../camel-atomix-value-kafka-sink-connector.adoc   |   3 +-
 .../camel-atomix-value-kafka-source-connector.adoc |   3 +-
 .../CamelAtomixvalueSinkConnectorConfig.java       |   4 -
 .../CamelAtomixvalueSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-avro-sink.json   |   7 -
 .../src/generated/resources/camel-avro-source.json |   7 -
 .../main/docs/camel-avro-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-avro-kafka-source-connector.adoc    |   3 +-
 .../avro/CamelAvroSinkConnectorConfig.java         |   4 -
 .../avro/CamelAvroSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-aws-cw-sink.json |   7 -
 .../docs/camel-aws-cw-kafka-sink-connector.adoc    |   3 +-
 .../awscw/CamelAwscwSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-aws-ddb-sink.json    |   7 -
 .../docs/camel-aws-ddb-kafka-sink-connector.adoc   |   3 +-
 .../awsddb/CamelAwsddbSinkConnectorConfig.java     |   4 -
 .../resources/camel-aws-ddbstream-source.json      |   7 -
 ...camel-aws-ddbstream-kafka-source-connector.adoc |   3 +-
 .../CamelAwsddbstreamSourceConnectorConfig.java    |   4 -
 .../generated/resources/camel-aws-ec2-sink.json    |   7 -
 .../docs/camel-aws-ec2-kafka-sink-connector.adoc   |   3 +-
 .../awsec2/CamelAwsec2SinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws-ecs-sink.json    |   7 -
 .../docs/camel-aws-ecs-kafka-sink-connector.adoc   |   3 +-
 .../awsecs/CamelAwsecsSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws-eks-sink.json    |   7 -
 .../docs/camel-aws-eks-kafka-sink-connector.adoc   |   3 +-
 .../awseks/CamelAwseksSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws-iam-sink.json    |   7 -
 .../docs/camel-aws-iam-kafka-sink-connector.adoc   |   3 +-
 .../awsiam/CamelAwsiamSinkConnectorConfig.java     |   4 -
 .../resources/camel-aws-kinesis-firehose-sink.json |   7 -
 ...-aws-kinesis-firehose-kafka-sink-connector.adoc |   3 +-
 ...CamelAwskinesisfirehoseSinkConnectorConfig.java |   4 -
 .../resources/camel-aws-kinesis-sink.json          |   7 -
 .../resources/camel-aws-kinesis-source.json        |   7 -
 .../camel-aws-kinesis-kafka-sink-connector.adoc    |   3 +-
 .../camel-aws-kinesis-kafka-source-connector.adoc  |   3 +-
 .../CamelAwskinesisSinkConnectorConfig.java        |   4 -
 .../CamelAwskinesisSourceConnectorConfig.java      |   4 -
 .../generated/resources/camel-aws-kms-sink.json    |   7 -
 .../docs/camel-aws-kms-kafka-sink-connector.adoc   |   3 +-
 .../awskms/CamelAwskmsSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws-lambda-sink.json |   7 -
 .../camel-aws-lambda-kafka-sink-connector.adoc     |   3 +-
 .../CamelAwslambdaSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-aws-mq-sink.json |   7 -
 .../docs/camel-aws-mq-kafka-sink-connector.adoc    |   3 +-
 .../awsmq/CamelAwsmqSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-aws-msk-sink.json    |   7 -
 .../docs/camel-aws-msk-kafka-sink-connector.adoc   |   3 +-
 .../awsmsk/CamelAwsmskSinkConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-aws-s3-sink.json |   7 -
 .../generated/resources/camel-aws-s3-source.json   |  19 +-
 .../docs/camel-aws-s3-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-aws-s3-kafka-source-connector.adoc  |   5 +-
 .../awss3/CamelAwss3SinkConnectorConfig.java       |   4 -
 .../awss3/CamelAwss3SourceConnectorConfig.java     |  12 +-
 .../generated/resources/camel-aws-sdb-sink.json    |   7 -
 .../docs/camel-aws-sdb-kafka-sink-connector.adoc   |   3 +-
 .../awssdb/CamelAwssdbSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws-ses-sink.json    |   7 -
 .../docs/camel-aws-ses-kafka-sink-connector.adoc   |   3 +-
 .../awsses/CamelAwssesSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws-sns-sink.json    |   7 -
 .../docs/camel-aws-sns-kafka-sink-connector.adoc   |   3 +-
 .../awssns/CamelAwssnsSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws-sqs-sink.json    |   7 -
 .../generated/resources/camel-aws-sqs-source.json  |   7 -
 .../docs/camel-aws-sqs-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-aws-sqs-kafka-source-connector.adoc |   3 +-
 .../awssqs/CamelAwssqsSinkConnectorConfig.java     |   4 -
 .../awssqs/CamelAwssqsSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-aws-swf-sink.json    |   7 -
 .../generated/resources/camel-aws-swf-source.json  |   7 -
 .../docs/camel-aws-swf-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-aws-swf-kafka-source-connector.adoc |   3 +-
 .../awsswf/CamelAwsswfSinkConnectorConfig.java     |   4 -
 .../awsswf/CamelAwsswfSourceConnectorConfig.java   |   4 -
 .../resources/camel-aws-translate-sink.json        |   7 -
 .../camel-aws-translate-kafka-sink-connector.adoc  |   3 +-
 .../CamelAwstranslateSinkConnectorConfig.java      |   4 -
 .../resources/camel-aws2-athena-sink.json          |   7 -
 .../camel-aws2-athena-kafka-sink-connector.adoc    |   3 +-
 .../CamelAws2athenaSinkConnectorConfig.java        |   4 -
 .../generated/resources/camel-aws2-cw-sink.json    |   7 -
 .../docs/camel-aws2-cw-kafka-sink-connector.adoc   |   3 +-
 .../aws2cw/CamelAws2cwSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws2-ddb-sink.json   |   7 -
 .../docs/camel-aws2-ddb-kafka-sink-connector.adoc  |   3 +-
 .../aws2ddb/CamelAws2ddbSinkConnectorConfig.java   |   4 -
 .../resources/camel-aws2-ddbstream-source.json     |   7 -
 ...amel-aws2-ddbstream-kafka-source-connector.adoc |   3 +-
 .../CamelAws2ddbstreamSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-aws2-ec2-sink.json   |   7 -
 .../docs/camel-aws2-ec2-kafka-sink-connector.adoc  |   3 +-
 .../aws2ec2/CamelAws2ec2SinkConnectorConfig.java   |   4 -
 .../generated/resources/camel-aws2-ecs-sink.json   |   7 -
 .../docs/camel-aws2-ecs-kafka-sink-connector.adoc  |   3 +-
 .../aws2ecs/CamelAws2ecsSinkConnectorConfig.java   |   4 -
 .../generated/resources/camel-aws2-eks-sink.json   |   7 -
 .../docs/camel-aws2-eks-kafka-sink-connector.adoc  |   3 +-
 .../aws2eks/CamelAws2eksSinkConnectorConfig.java   |   4 -
 .../resources/camel-aws2-eventbridge-sink.json     |   7 -
 ...amel-aws2-eventbridge-kafka-sink-connector.adoc |   3 +-
 .../CamelAws2eventbridgeSinkConnectorConfig.java   |   4 -
 .../generated/resources/camel-aws2-iam-sink.json   |  19 +-
 .../docs/camel-aws2-iam-kafka-sink-connector.adoc  |   7 +-
 .../examples/CamelAws2iamSinkConnector.properties  |   4 -
 .../aws2iam/CamelAws2iamSinkConnectorConfig.java   |  12 +-
 .../camel-aws2-kinesis-firehose-sink.json          |  27 +-
 ...aws2-kinesis-firehose-kafka-sink-connector.adoc |   7 +-
 ...amelAws2kinesisfirehoseSinkConnectorConfig.java |  20 +-
 .../resources/camel-aws2-kinesis-sink.json         |  33 +-
 .../resources/camel-aws2-kinesis-source.json       |  33 +-
 .../camel-aws2-kinesis-kafka-sink-connector.adoc   |   7 +-
 .../camel-aws2-kinesis-kafka-source-connector.adoc |   7 +-
 .../CamelAws2kinesisSinkConnectorConfig.java       |  20 +-
 .../CamelAws2kinesisSourceConnectorConfig.java     |  20 +-
 .../generated/resources/camel-aws2-kms-sink.json   |   7 -
 .../docs/camel-aws2-kms-kafka-sink-connector.adoc  |   3 +-
 .../aws2kms/CamelAws2kmsSinkConnectorConfig.java   |   4 -
 .../resources/camel-aws2-lambda-sink.json          |   7 -
 .../camel-aws2-lambda-kafka-sink-connector.adoc    |   3 +-
 .../CamelAws2lambdaSinkConnectorConfig.java        |   4 -
 .../generated/resources/camel-aws2-mq-sink.json    |   7 -
 .../docs/camel-aws2-mq-kafka-sink-connector.adoc   |   3 +-
 .../aws2mq/CamelAws2mqSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-aws2-msk-sink.json   |   7 -
 .../docs/camel-aws2-msk-kafka-sink-connector.adoc  |   3 +-
 .../aws2msk/CamelAws2mskSinkConnectorConfig.java   |   4 -
 .../generated/resources/camel-aws2-s3-sink.json    |   7 -
 .../generated/resources/camel-aws2-s3-source.json  |  19 +-
 .../docs/camel-aws2-s3-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-aws2-s3-kafka-source-connector.adoc |   5 +-
 .../aws2s3/CamelAws2s3SinkConnectorConfig.java     |   4 -
 .../aws2s3/CamelAws2s3SourceConnectorConfig.java   |  12 +-
 .../generated/resources/camel-aws2-ses-sink.json   |   7 -
 .../docs/camel-aws2-ses-kafka-sink-connector.adoc  |   3 +-
 .../aws2ses/CamelAws2sesSinkConnectorConfig.java   |   4 -
 .../generated/resources/camel-aws2-sns-sink.json   |  11 +-
 .../docs/camel-aws2-sns-kafka-sink-connector.adoc  |   7 +-
 .../aws2sns/CamelAws2snsSinkConnectorConfig.java   |   8 +-
 .../generated/resources/camel-aws2-sqs-sink.json   |  25 +-
 .../generated/resources/camel-aws2-sqs-source.json |  11 +-
 .../docs/camel-aws2-sqs-kafka-sink-connector.adoc  |   9 +-
 .../camel-aws2-sqs-kafka-source-connector.adoc     |   7 +-
 .../aws2sqs/CamelAws2sqsSinkConnectorConfig.java   |  16 +-
 .../aws2sqs/CamelAws2sqsSourceConnectorConfig.java |   8 +-
 .../generated/resources/camel-aws2-sts-sink.json   |   7 -
 .../docs/camel-aws2-sts-kafka-sink-connector.adoc  |   3 +-
 .../aws2sts/CamelAws2stsSinkConnectorConfig.java   |   4 -
 .../resources/camel-aws2-translate-sink.json       |   7 -
 .../camel-aws2-translate-kafka-sink-connector.adoc |   3 +-
 .../CamelAws2translateSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-azure-blob-sink.json |   7 -
 .../resources/camel-azure-blob-source.json         |   7 -
 .../camel-azure-blob-kafka-sink-connector.adoc     |   3 +-
 .../camel-azure-blob-kafka-source-connector.adoc   |   3 +-
 .../CamelAzureblobSinkConnectorConfig.java         |   4 -
 .../CamelAzureblobSourceConnectorConfig.java       |   4 -
 .../resources/camel-azure-eventhubs-sink.json      |   7 -
 .../resources/camel-azure-eventhubs-source.json    |   7 -
 ...camel-azure-eventhubs-kafka-sink-connector.adoc |   3 +-
 ...mel-azure-eventhubs-kafka-source-connector.adoc |   3 +-
 .../CamelAzureeventhubsSinkConnectorConfig.java    |   4 -
 .../CamelAzureeventhubsSourceConnectorConfig.java  |   4 -
 .../resources/camel-azure-queue-sink.json          |   7 -
 .../resources/camel-azure-queue-source.json        |   7 -
 .../camel-azure-queue-kafka-sink-connector.adoc    |   3 +-
 .../camel-azure-queue-kafka-source-connector.adoc  |   3 +-
 .../CamelAzurequeueSinkConnectorConfig.java        |   4 -
 .../CamelAzurequeueSourceConnectorConfig.java      |   4 -
 .../resources/camel-azure-storage-blob-sink.json   |   7 -
 .../resources/camel-azure-storage-blob-source.json |   7 -
 ...el-azure-storage-blob-kafka-sink-connector.adoc |   3 +-
 ...-azure-storage-blob-kafka-source-connector.adoc |   3 +-
 .../CamelAzurestorageblobSinkConnectorConfig.java  |   4 -
 ...CamelAzurestorageblobSourceConnectorConfig.java |   4 -
 .../pom.xml                                        | 139 +++++++
 .../descriptors/connector-sink.properties          |   1 +
 .../descriptors/connector-source.properties        |   1 +
 .../camel-azure-storage-datalake-sink.json         | 416 ++++++++++++++++++++
 .../camel-azure-storage-datalake-source.json       | 411 ++++++++++++++++++++
 .../src/main/assembly/package.xml                  |  57 +++
 ...zure-storage-datalake-kafka-sink-connector.adoc | 116 ++++++
 ...re-storage-datalake-kafka-source-connector.adoc | 116 ++++++
 ...melAzurestoragedatalakeSinkConnector.properties |  31 ++
 ...lAzurestoragedatalakeSourceConnector.properties |  31 ++
 .../CamelAzurestoragedatalakeSinkConnector.java    |  37 ++
 ...melAzurestoragedatalakeSinkConnectorConfig.java | 305 +++++++++++++++
 .../CamelAzurestoragedatalakeSinkTask.java         |  39 ++
 .../CamelAzurestoragedatalakeSourceConnector.java  |  37 ++
 ...lAzurestoragedatalakeSourceConnectorConfig.java | 305 +++++++++++++++
 .../CamelAzurestoragedatalakeSourceTask.java       |  39 ++
 .../src/main/resources/META-INF/LICENSE.txt        | 203 ++++++++++
 .../src/main/resources/META-INF/NOTICE.txt         |  11 +
 .../resources/camel-azure-storage-queue-sink.json  |   7 -
 .../camel-azure-storage-queue-source.json          |   7 -
 ...l-azure-storage-queue-kafka-sink-connector.adoc |   3 +-
 ...azure-storage-queue-kafka-source-connector.adoc |   3 +-
 .../CamelAzurestoragequeueSinkConnectorConfig.java |   4 -
 ...amelAzurestoragequeueSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-bean-sink.json   |   7 -
 .../main/docs/camel-bean-kafka-sink-connector.adoc |   3 +-
 .../bean/CamelBeanSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-beanstalk-sink.json  |   7 -
 .../resources/camel-beanstalk-source.json          |   7 -
 .../docs/camel-beanstalk-kafka-sink-connector.adoc |   3 +-
 .../camel-beanstalk-kafka-source-connector.adoc    |   3 +-
 .../CamelBeanstalkSinkConnectorConfig.java         |   4 -
 .../CamelBeanstalkSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-box-sink.json    |   7 -
 .../src/generated/resources/camel-box-source.json  |   7 -
 .../main/docs/camel-box-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-box-kafka-source-connector.adoc     |   3 +-
 .../box/CamelBoxSinkConnectorConfig.java           |   4 -
 .../box/CamelBoxSourceConnectorConfig.java         |   4 -
 .../generated/resources/camel-braintree-sink.json  |   7 -
 .../docs/camel-braintree-kafka-sink-connector.adoc |   3 +-
 .../CamelBraintreeSinkConnectorConfig.java         |   4 -
 .../resources/camel-caffeine-cache-sink.json       |   7 -
 .../camel-caffeine-cache-kafka-sink-connector.adoc |   3 +-
 .../CamelCaffeinecacheSinkConnectorConfig.java     |   4 -
 .../resources/camel-caffeine-loadcache-sink.json   |   7 -
 ...el-caffeine-loadcache-kafka-sink-connector.adoc |   3 +-
 .../CamelCaffeineloadcacheSinkConnectorConfig.java |   4 -
 .../generated/resources/camel-chatscript-sink.json |   7 -
 .../camel-chatscript-kafka-sink-connector.adoc     |   3 +-
 .../CamelChatscriptSinkConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-chunk-sink.json  |   7 -
 .../docs/camel-chunk-kafka-sink-connector.adoc     |   3 +-
 .../chunk/CamelChunkSinkConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-cm-sms-sink.json |   7 -
 .../docs/camel-cm-sms-kafka-sink-connector.adoc    |   3 +-
 .../cmsms/CamelCmsmsSinkConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-cmis-sink.json   |   7 -
 .../src/generated/resources/camel-cmis-source.json |   7 -
 .../main/docs/camel-cmis-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-cmis-kafka-source-connector.adoc    |   3 +-
 .../cmis/CamelCmisSinkConnectorConfig.java         |   4 -
 .../cmis/CamelCmisSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-coap-sink.json   |   7 -
 .../src/generated/resources/camel-coap-source.json |   7 -
 .../main/docs/camel-coap-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-coap-kafka-source-connector.adoc    |   3 +-
 .../coap/CamelCoapSinkConnectorConfig.java         |   4 -
 .../coap/CamelCoapSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-coap+tcp-sink.json   |   7 -
 .../generated/resources/camel-coap+tcp-source.json |   7 -
 .../docs/camel-coap+tcp-kafka-sink-connector.adoc  |   3 +-
 .../camel-coap+tcp-kafka-source-connector.adoc     |   3 +-
 .../coaptcp/CamelCoaptcpSinkConnectorConfig.java   |   4 -
 .../coaptcp/CamelCoaptcpSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-coaps-sink.json  |   7 -
 .../generated/resources/camel-coaps-source.json    |   7 -
 .../docs/camel-coaps-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-coaps-kafka-source-connector.adoc   |   3 +-
 .../coaps/CamelCoapsSinkConnectorConfig.java       |   4 -
 .../coaps/CamelCoapsSourceConnectorConfig.java     |   4 -
 .../generated/resources/camel-coaps+tcp-sink.json  |   7 -
 .../resources/camel-coaps+tcp-source.json          |   7 -
 .../docs/camel-coaps+tcp-kafka-sink-connector.adoc |   3 +-
 .../camel-coaps+tcp-kafka-source-connector.adoc    |   3 +-
 .../coapstcp/CamelCoapstcpSinkConnectorConfig.java |   4 -
 .../CamelCoapstcpSourceConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-cometd-sink.json |   7 -
 .../generated/resources/camel-cometd-source.json   |   7 -
 .../docs/camel-cometd-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-cometd-kafka-source-connector.adoc  |   3 +-
 .../cometd/CamelCometdSinkConnectorConfig.java     |   4 -
 .../cometd/CamelCometdSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-cometds-sink.json    |   7 -
 .../generated/resources/camel-cometds-source.json  |   7 -
 .../docs/camel-cometds-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-cometds-kafka-source-connector.adoc |   3 +-
 .../cometds/CamelCometdsSinkConnectorConfig.java   |   4 -
 .../cometds/CamelCometdsSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-consul-sink.json |   7 -
 .../generated/resources/camel-consul-source.json   |   7 -
 .../docs/camel-consul-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-consul-kafka-source-connector.adoc  |   3 +-
 .../consul/CamelConsulSinkConnectorConfig.java     |   4 -
 .../consul/CamelConsulSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-controlbus-sink.json |   7 -
 .../camel-controlbus-kafka-sink-connector.adoc     |   3 +-
 .../CamelControlbusSinkConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-corda-sink.json  |   7 -
 .../generated/resources/camel-corda-source.json    |   7 -
 .../docs/camel-corda-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-corda-kafka-source-connector.adoc   |   3 +-
 .../corda/CamelCordaSinkConnectorConfig.java       |   4 -
 .../corda/CamelCordaSourceConnectorConfig.java     |   4 -
 .../generated/resources/camel-couchbase-sink.json  |   7 -
 .../resources/camel-couchbase-source.json          |   7 -
 .../docs/camel-couchbase-kafka-sink-connector.adoc |   3 +-
 .../camel-couchbase-kafka-source-connector.adoc    |   3 +-
 .../CamelCouchbaseSinkConnectorConfig.java         |   4 -
 .../CamelCouchbaseSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-couchdb-sink.json    |   7 -
 .../generated/resources/camel-couchdb-source.json  |   7 -
 .../docs/camel-couchdb-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-couchdb-kafka-source-connector.adoc |   3 +-
 .../couchdb/CamelCouchdbSinkConnectorConfig.java   |   4 -
 .../couchdb/CamelCouchdbSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-cql-sink.json    |   7 -
 .../src/generated/resources/camel-cql-source.json  |   7 -
 .../main/docs/camel-cql-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-cql-kafka-source-connector.adoc     |   3 +-
 .../cql/CamelCqlSinkConnectorConfig.java           |   4 -
 .../cql/CamelCqlSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-cron-source.json |   7 -
 .../docs/camel-cron-kafka-source-connector.adoc    |   3 +-
 .../cron/CamelCronSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-crypto-cms-sink.json |   7 -
 .../camel-crypto-cms-kafka-sink-connector.adoc     |   3 +-
 .../CamelCryptocmsSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-crypto-sink.json |   7 -
 .../docs/camel-crypto-kafka-sink-connector.adoc    |   3 +-
 .../crypto/CamelCryptoSinkConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-cxf-sink.json    |  14 +-
 .../src/generated/resources/camel-cxf-source.json  |   7 -
 .../main/docs/camel-cxf-kafka-sink-connector.adoc  |   2 +-
 .../docs/camel-cxf-kafka-source-connector.adoc     |   3 +-
 .../cxf/CamelCxfSinkConnectorConfig.java           |   8 +-
 .../cxf/CamelCxfSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-cxfrs-sink.json  |  14 +-
 .../generated/resources/camel-cxfrs-source.json    |   7 -
 .../docs/camel-cxfrs-kafka-sink-connector.adoc     |   2 +-
 .../docs/camel-cxfrs-kafka-source-connector.adoc   |   3 +-
 .../cxfrs/CamelCxfrsSinkConnectorConfig.java       |   8 +-
 .../cxfrs/CamelCxfrsSourceConnectorConfig.java     |   4 -
 .../generated/resources/camel-dataformat-sink.json |   7 -
 .../camel-dataformat-kafka-sink-connector.adoc     |   3 +-
 .../CamelDataformatSinkConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-direct-sink.json |   2 +-
 .../generated/resources/camel-direct-source.json   |   2 +-
 .../docs/camel-direct-kafka-sink-connector.adoc    |   2 +-
 .../docs/camel-direct-kafka-source-connector.adoc  |   2 +-
 .../direct/CamelDirectSinkConnectorConfig.java     |   2 +-
 .../direct/CamelDirectSourceConnectorConfig.java   |   2 +-
 .../generated/resources/camel-direct-vm-sink.json  |   7 -
 .../resources/camel-direct-vm-source.json          |   7 -
 .../docs/camel-direct-vm-kafka-sink-connector.adoc |   3 +-
 .../camel-direct-vm-kafka-source-connector.adoc    |   3 +-
 .../directvm/CamelDirectvmSinkConnectorConfig.java |   4 -
 .../CamelDirectvmSourceConnectorConfig.java        |   4 -
 .../generated/resources/camel-disruptor-sink.json  |   7 -
 .../resources/camel-disruptor-source.json          |   7 -
 .../docs/camel-disruptor-kafka-sink-connector.adoc |   3 +-
 .../camel-disruptor-kafka-source-connector.adoc    |   3 +-
 .../CamelDisruptorSinkConnectorConfig.java         |   4 -
 .../CamelDisruptorSourceConnectorConfig.java       |   4 -
 .../resources/camel-disruptor-vm-sink.json         |   7 -
 .../resources/camel-disruptor-vm-source.json       |   7 -
 .../camel-disruptor-vm-kafka-sink-connector.adoc   |   3 +-
 .../camel-disruptor-vm-kafka-source-connector.adoc |   3 +-
 .../CamelDisruptorvmSinkConnectorConfig.java       |   4 -
 .../CamelDisruptorvmSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-djl-sink.json    |   7 -
 .../main/docs/camel-djl-kafka-sink-connector.adoc  |   3 +-
 .../djl/CamelDjlSinkConnectorConfig.java           |   4 -
 .../src/generated/resources/camel-dns-sink.json    |   7 -
 .../main/docs/camel-dns-kafka-sink-connector.adoc  |   3 +-
 .../dns/CamelDnsSinkConnectorConfig.java           |   4 -
 .../src/generated/resources/camel-docker-sink.json |   7 -
 .../generated/resources/camel-docker-source.json   |   7 -
 .../docs/camel-docker-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-docker-kafka-source-connector.adoc  |   3 +-
 .../docker/CamelDockerSinkConnectorConfig.java     |   4 -
 .../docker/CamelDockerSourceConnectorConfig.java   |   4 -
 .../src/generated/resources/camel-dozer-sink.json  |   7 -
 .../docs/camel-dozer-kafka-sink-connector.adoc     |   3 +-
 .../dozer/CamelDozerSinkConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-drill-sink.json  |   7 -
 .../docs/camel-drill-kafka-sink-connector.adoc     |   3 +-
 .../drill/CamelDrillSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-dropbox-sink.json    |   7 -
 .../generated/resources/camel-dropbox-source.json  |   7 -
 .../docs/camel-dropbox-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-dropbox-kafka-source-connector.adoc |   3 +-
 .../dropbox/CamelDropboxSinkConnectorConfig.java   |   4 -
 .../dropbox/CamelDropboxSourceConnectorConfig.java |   4 -
 .../generated/resources/camel-ehcache-sink.json    |   7 -
 .../generated/resources/camel-ehcache-source.json  |   7 -
 .../docs/camel-ehcache-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-ehcache-kafka-source-connector.adoc |   3 +-
 .../ehcache/CamelEhcacheSinkConnectorConfig.java   |   4 -
 .../ehcache/CamelEhcacheSourceConnectorConfig.java |   4 -
 .../resources/camel-elasticsearch-rest-sink.json   |   7 -
 ...el-elasticsearch-rest-kafka-sink-connector.adoc |   3 +-
 .../CamelElasticsearchrestSinkConnectorConfig.java |   4 -
 .../src/generated/resources/camel-elsql-sink.json  |   7 -
 .../generated/resources/camel-elsql-source.json    |   7 -
 .../docs/camel-elsql-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-elsql-kafka-source-connector.adoc   |   3 +-
 .../elsql/CamelElsqlSinkConnectorConfig.java       |   4 -
 .../elsql/CamelElsqlSourceConnectorConfig.java     |   4 -
 .../generated/resources/camel-etcd-keys-sink.json  |   7 -
 .../docs/camel-etcd-keys-kafka-sink-connector.adoc |   3 +-
 .../etcdkeys/CamelEtcdkeysSinkConnectorConfig.java |   4 -
 .../generated/resources/camel-etcd-stats-sink.json |   7 -
 .../resources/camel-etcd-stats-source.json         |   7 -
 .../camel-etcd-stats-kafka-sink-connector.adoc     |   3 +-
 .../camel-etcd-stats-kafka-source-connector.adoc   |   3 +-
 .../CamelEtcdstatsSinkConnectorConfig.java         |   4 -
 .../CamelEtcdstatsSourceConnectorConfig.java       |   4 -
 .../resources/camel-etcd-watch-source.json         |   7 -
 .../camel-etcd-watch-kafka-source-connector.adoc   |   3 +-
 .../CamelEtcdwatchSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-exec-sink.json   |   7 -
 .../main/docs/camel-exec-kafka-sink-connector.adoc |   3 +-
 .../exec/CamelExecSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-facebook-sink.json   |   7 -
 .../generated/resources/camel-facebook-source.json |   7 -
 .../docs/camel-facebook-kafka-sink-connector.adoc  |   3 +-
 .../camel-facebook-kafka-source-connector.adoc     |   3 +-
 .../facebook/CamelFacebookSinkConnectorConfig.java |   4 -
 .../CamelFacebookSourceConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-fhir-sink.json   |   7 -
 .../src/generated/resources/camel-fhir-source.json |   7 -
 .../main/docs/camel-fhir-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-fhir-kafka-source-connector.adoc    |   3 +-
 .../fhir/CamelFhirSinkConnectorConfig.java         |   4 -
 .../fhir/CamelFhirSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-file-sink.json   |   2 +-
 .../src/generated/resources/camel-file-source.json |  14 +-
 .../main/docs/camel-file-kafka-sink-connector.adoc |   2 +-
 .../docs/camel-file-kafka-source-connector.adoc    |   6 +-
 .../file/CamelFileSinkConnectorConfig.java         |   2 +-
 .../file/CamelFileSourceConnectorConfig.java       |  10 +-
 .../resources/camel-file-watch-source.json         |   7 -
 .../camel-file-watch-kafka-source-connector.adoc   |   3 +-
 .../CamelFilewatchSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-flatpack-sink.json   |   7 -
 .../generated/resources/camel-flatpack-source.json |   7 -
 .../docs/camel-flatpack-kafka-sink-connector.adoc  |   3 +-
 .../camel-flatpack-kafka-source-connector.adoc     |   3 +-
 .../flatpack/CamelFlatpackSinkConnectorConfig.java |   4 -
 .../CamelFlatpackSourceConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-flink-sink.json  |   7 -
 .../docs/camel-flink-kafka-sink-connector.adoc     |   3 +-
 .../flink/CamelFlinkSinkConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-fop-sink.json    |   7 -
 .../main/docs/camel-fop-kafka-sink-connector.adoc  |   3 +-
 .../fop/CamelFopSinkConnectorConfig.java           |   4 -
 .../generated/resources/camel-freemarker-sink.json |   7 -
 .../camel-freemarker-kafka-sink-connector.adoc     |   3 +-
 .../CamelFreemarkerSinkConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-ftp-sink.json    |   2 +-
 .../src/generated/resources/camel-ftp-source.json  |  14 +-
 .../main/docs/camel-ftp-kafka-sink-connector.adoc  |   2 +-
 .../docs/camel-ftp-kafka-source-connector.adoc     |   6 +-
 .../ftp/CamelFtpSinkConnectorConfig.java           |   2 +-
 .../ftp/CamelFtpSourceConnectorConfig.java         |  10 +-
 .../src/generated/resources/camel-ftps-sink.json   |   2 +-
 .../src/generated/resources/camel-ftps-source.json |  14 +-
 .../main/docs/camel-ftps-kafka-sink-connector.adoc |   2 +-
 .../docs/camel-ftps-kafka-source-connector.adoc    |   6 +-
 .../ftps/CamelFtpsSinkConnectorConfig.java         |   2 +-
 .../ftps/CamelFtpsSourceConnectorConfig.java       |  10 +-
 .../generated/resources/camel-ganglia-sink.json    |   7 -
 .../docs/camel-ganglia-kafka-sink-connector.adoc   |   3 +-
 .../ganglia/CamelGangliaSinkConnectorConfig.java   |   4 -
 .../generated/resources/camel-geocoder-sink.json   |   7 -
 .../docs/camel-geocoder-kafka-sink-connector.adoc  |   3 +-
 .../geocoder/CamelGeocoderSinkConnectorConfig.java |   4 -
 .../src/generated/resources/camel-git-sink.json    |   7 -
 .../src/generated/resources/camel-git-source.json  |   7 -
 .../main/docs/camel-git-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-git-kafka-source-connector.adoc     |   3 +-
 .../git/CamelGitSinkConnectorConfig.java           |   4 -
 .../git/CamelGitSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-github-sink.json |   7 -
 .../generated/resources/camel-github-source.json   |   7 -
 .../docs/camel-github-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-github-kafka-source-connector.adoc  |   3 +-
 .../github/CamelGithubSinkConnectorConfig.java     |   4 -
 .../github/CamelGithubSourceConnectorConfig.java   |   4 -
 .../resources/camel-google-bigquery-sink.json      |   7 -
 ...camel-google-bigquery-kafka-sink-connector.adoc |   3 +-
 .../CamelGooglebigquerySinkConnectorConfig.java    |   4 -
 .../resources/camel-google-bigquery-sql-sink.json  |   7 -
 ...l-google-bigquery-sql-kafka-sink-connector.adoc |   3 +-
 .../CamelGooglebigquerysqlSinkConnectorConfig.java |   4 -
 .../resources/camel-google-calendar-sink.json      |  79 ++--
 .../resources/camel-google-calendar-source.json    |  79 ++--
 ...camel-google-calendar-kafka-sink-connector.adoc |  15 +-
 ...mel-google-calendar-kafka-source-connector.adoc |  15 +-
 .../CamelGooglecalendarSinkConnectorConfig.java    |  52 ++-
 .../CamelGooglecalendarSourceConnectorConfig.java  |  52 ++-
 .../camel-google-calendar-stream-source.json       |  57 ++-
 ...gle-calendar-stream-kafka-source-connector.adoc |  11 +-
 ...lGooglecalendarstreamSourceConnectorConfig.java |  36 +-
 .../resources/camel-google-drive-sink.json         |   7 -
 .../resources/camel-google-drive-source.json       |   7 -
 .../camel-google-drive-kafka-sink-connector.adoc   |   3 +-
 .../camel-google-drive-kafka-source-connector.adoc |   3 +-
 .../CamelGoogledriveSinkConnectorConfig.java       |   4 -
 .../CamelGoogledriveSourceConnectorConfig.java     |   4 -
 .../resources/camel-google-mail-sink.json          |   7 -
 .../resources/camel-google-mail-source.json        |   7 -
 .../camel-google-mail-kafka-sink-connector.adoc    |   3 +-
 .../camel-google-mail-kafka-source-connector.adoc  |   3 +-
 .../CamelGooglemailSinkConnectorConfig.java        |   4 -
 .../CamelGooglemailSourceConnectorConfig.java      |   4 -
 .../resources/camel-google-mail-stream-source.json |   7 -
 ...-google-mail-stream-kafka-source-connector.adoc |   3 +-
 ...CamelGooglemailstreamSourceConnectorConfig.java |   4 -
 .../resources/camel-google-pubsub-sink.json        |  20 +-
 .../resources/camel-google-pubsub-source.json      |   7 -
 .../camel-google-pubsub-kafka-sink-connector.adoc  |   5 +-
 ...camel-google-pubsub-kafka-source-connector.adoc |   3 +-
 .../CamelGooglepubsubSinkConnectorConfig.java      |  12 +-
 .../CamelGooglepubsubSourceConnectorConfig.java    |   4 -
 .../resources/camel-google-sheets-sink.json        |   7 -
 .../resources/camel-google-sheets-source.json      |   7 -
 .../camel-google-sheets-kafka-sink-connector.adoc  |   3 +-
 ...camel-google-sheets-kafka-source-connector.adoc |   3 +-
 .../CamelGooglesheetsSinkConnectorConfig.java      |   4 -
 .../CamelGooglesheetsSourceConnectorConfig.java    |   4 -
 .../camel-google-sheets-stream-source.json         |   7 -
 ...oogle-sheets-stream-kafka-source-connector.adoc |   3 +-
 ...melGooglesheetsstreamSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-gora-sink.json   |   7 -
 .../src/generated/resources/camel-gora-source.json |   7 -
 .../main/docs/camel-gora-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-gora-kafka-source-connector.adoc    |   3 +-
 .../gora/CamelGoraSinkConnectorConfig.java         |   4 -
 .../gora/CamelGoraSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-grape-sink.json  |   7 -
 .../docs/camel-grape-kafka-sink-connector.adoc     |   3 +-
 .../grape/CamelGrapeSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-graphql-sink.json    |   7 -
 .../docs/camel-graphql-kafka-sink-connector.adoc   |   3 +-
 .../graphql/CamelGraphqlSinkConnectorConfig.java   |   4 -
 .../src/generated/resources/camel-grpc-sink.json   |   2 +-
 .../src/generated/resources/camel-grpc-source.json |   2 +-
 .../main/docs/camel-grpc-kafka-sink-connector.adoc |   2 +-
 .../docs/camel-grpc-kafka-source-connector.adoc    |   2 +-
 .../grpc/CamelGrpcSinkConnectorConfig.java         |   2 +-
 .../grpc/CamelGrpcSourceConnectorConfig.java       |   2 +-
 .../resources/camel-guava-eventbus-sink.json       |   7 -
 .../resources/camel-guava-eventbus-source.json     |   7 -
 .../camel-guava-eventbus-kafka-sink-connector.adoc |   3 +-
 ...amel-guava-eventbus-kafka-source-connector.adoc |   3 +-
 .../CamelGuavaeventbusSinkConnectorConfig.java     |   4 -
 .../CamelGuavaeventbusSourceConnectorConfig.java   |   4 -
 .../camel-hazelcast-atomicvalue-sink.json          |   7 -
 ...hazelcast-atomicvalue-kafka-sink-connector.adoc |   3 +-
 ...melHazelcastatomicvalueSinkConnectorConfig.java |   4 -
 .../resources/camel-hazelcast-instance-source.json |   7 -
 ...-hazelcast-instance-kafka-source-connector.adoc |   3 +-
 ...amelHazelcastinstanceSourceConnectorConfig.java |   4 -
 .../resources/camel-hazelcast-list-sink.json       |   7 -
 .../resources/camel-hazelcast-list-source.json     |   7 -
 .../camel-hazelcast-list-kafka-sink-connector.adoc |   3 +-
 ...amel-hazelcast-list-kafka-source-connector.adoc |   3 +-
 .../CamelHazelcastlistSinkConnectorConfig.java     |   4 -
 .../CamelHazelcastlistSourceConnectorConfig.java   |   4 -
 .../resources/camel-hazelcast-map-sink.json        |   7 -
 .../resources/camel-hazelcast-map-source.json      |   7 -
 .../camel-hazelcast-map-kafka-sink-connector.adoc  |   3 +-
 ...camel-hazelcast-map-kafka-source-connector.adoc |   3 +-
 .../CamelHazelcastmapSinkConnectorConfig.java      |   4 -
 .../CamelHazelcastmapSourceConnectorConfig.java    |   4 -
 .../resources/camel-hazelcast-multimap-sink.json   |   7 -
 .../resources/camel-hazelcast-multimap-source.json |   7 -
 ...el-hazelcast-multimap-kafka-sink-connector.adoc |   3 +-
 ...-hazelcast-multimap-kafka-source-connector.adoc |   3 +-
 .../CamelHazelcastmultimapSinkConnectorConfig.java |   4 -
 ...amelHazelcastmultimapSourceConnectorConfig.java |   4 -
 .../resources/camel-hazelcast-queue-sink.json      |   7 -
 .../resources/camel-hazelcast-queue-source.json    |   7 -
 ...camel-hazelcast-queue-kafka-sink-connector.adoc |   3 +-
 ...mel-hazelcast-queue-kafka-source-connector.adoc |   3 +-
 .../CamelHazelcastqueueSinkConnectorConfig.java    |   4 -
 .../CamelHazelcastqueueSourceConnectorConfig.java  |   4 -
 .../camel-hazelcast-replicatedmap-sink.json        |   7 -
 .../camel-hazelcast-replicatedmap-source.json      |   7 -
 ...zelcast-replicatedmap-kafka-sink-connector.adoc |   3 +-
 ...lcast-replicatedmap-kafka-source-connector.adoc |   3 +-
 ...lHazelcastreplicatedmapSinkConnectorConfig.java |   4 -
 ...azelcastreplicatedmapSourceConnectorConfig.java |   4 -
 .../resources/camel-hazelcast-ringbuffer-sink.json |   7 -
 ...-hazelcast-ringbuffer-kafka-sink-connector.adoc |   3 +-
 ...amelHazelcastringbufferSinkConnectorConfig.java |   4 -
 .../resources/camel-hazelcast-seda-sink.json       |   7 -
 .../resources/camel-hazelcast-seda-source.json     |   7 -
 .../camel-hazelcast-seda-kafka-sink-connector.adoc |   3 +-
 ...amel-hazelcast-seda-kafka-source-connector.adoc |   3 +-
 .../CamelHazelcastsedaSinkConnectorConfig.java     |   4 -
 .../CamelHazelcastsedaSourceConnectorConfig.java   |   4 -
 .../resources/camel-hazelcast-set-sink.json        |   7 -
 .../resources/camel-hazelcast-set-source.json      |   7 -
 .../camel-hazelcast-set-kafka-sink-connector.adoc  |   3 +-
 ...camel-hazelcast-set-kafka-source-connector.adoc |   3 +-
 .../CamelHazelcastsetSinkConnectorConfig.java      |   4 -
 .../CamelHazelcastsetSourceConnectorConfig.java    |   4 -
 .../resources/camel-hazelcast-topic-sink.json      |   7 -
 .../resources/camel-hazelcast-topic-source.json    |   7 -
 ...camel-hazelcast-topic-kafka-sink-connector.adoc |   3 +-
 ...mel-hazelcast-topic-kafka-source-connector.adoc |   3 +-
 .../CamelHazelcasttopicSinkConnectorConfig.java    |   4 -
 .../CamelHazelcasttopicSourceConnectorConfig.java  |   4 -
 .../src/generated/resources/camel-hbase-sink.json  |   7 -
 .../generated/resources/camel-hbase-source.json    |   7 -
 .../docs/camel-hbase-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-hbase-kafka-source-connector.adoc   |   3 +-
 .../hbase/CamelHbaseSinkConnectorConfig.java       |   4 -
 .../hbase/CamelHbaseSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-hdfs-sink.json   |   7 -
 .../src/generated/resources/camel-hdfs-source.json |   7 -
 .../main/docs/camel-hdfs-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-hdfs-kafka-source-connector.adoc    |   3 +-
 .../hdfs/CamelHdfsSinkConnectorConfig.java         |   4 -
 .../hdfs/CamelHdfsSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-http-sink.json   |   7 -
 .../main/docs/camel-http-kafka-sink-connector.adoc |   3 +-
 .../http/CamelHttpSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-https-sink.json  |   7 -
 .../docs/camel-https-kafka-sink-connector.adoc     |   3 +-
 .../https/CamelHttpsSinkConnectorConfig.java       |   4 -
 .../camel-hwcloud-smn-kafka-connector/pom.xml      | 139 +++++++
 .../descriptors/connector-sink.properties          |   1 +
 .../resources/camel-hwcloud-smn-sink.json          | 114 ++++++
 .../src/main/assembly/package.xml                  |  57 +++
 .../camel-hwcloud-smn-kafka-sink-connector.adoc    |  67 ++++
 .../CamelHwcloudsmnSinkConnector.properties        |  43 +++
 .../hwcloudsmn/CamelHwcloudsmnSinkConnector.java   |  35 ++
 .../CamelHwcloudsmnSinkConnectorConfig.java        | 108 ++++++
 .../hwcloudsmn/CamelHwcloudsmnSinkTask.java        |  39 ++
 .../src/main/resources/META-INF/LICENSE.txt        | 203 ++++++++++
 .../src/main/resources/META-INF/NOTICE.txt         |  11 +
 .../resources/camel-iec60870-client-sink.json      |   7 -
 .../resources/camel-iec60870-client-source.json    |   7 -
 ...camel-iec60870-client-kafka-sink-connector.adoc |   3 +-
 ...mel-iec60870-client-kafka-source-connector.adoc |   3 +-
 .../CamelIec60870clientSinkConnectorConfig.java    |   4 -
 .../CamelIec60870clientSourceConnectorConfig.java  |   4 -
 .../resources/camel-iec60870-server-sink.json      |   7 -
 .../resources/camel-iec60870-server-source.json    |   7 -
 ...camel-iec60870-server-kafka-sink-connector.adoc |   3 +-
 ...mel-iec60870-server-kafka-source-connector.adoc |   3 +-
 .../CamelIec60870serverSinkConnectorConfig.java    |   4 -
 .../CamelIec60870serverSourceConnectorConfig.java  |   4 -
 .../resources/camel-ignite-cache-sink.json         |   7 -
 .../resources/camel-ignite-cache-source.json       |   7 -
 .../camel-ignite-cache-kafka-sink-connector.adoc   |   3 +-
 .../camel-ignite-cache-kafka-source-connector.adoc |   3 +-
 .../CamelIgnitecacheSinkConnectorConfig.java       |   4 -
 .../CamelIgnitecacheSourceConnectorConfig.java     |   4 -
 .../resources/camel-ignite-compute-sink.json       |   7 -
 .../camel-ignite-compute-kafka-sink-connector.adoc |   3 +-
 .../CamelIgnitecomputeSinkConnectorConfig.java     |   4 -
 .../resources/camel-ignite-events-source.json      |   7 -
 ...camel-ignite-events-kafka-source-connector.adoc |   3 +-
 .../CamelIgniteeventsSourceConnectorConfig.java    |   4 -
 .../resources/camel-ignite-idgen-sink.json         |   7 -
 .../camel-ignite-idgen-kafka-sink-connector.adoc   |   3 +-
 .../CamelIgniteidgenSinkConnectorConfig.java       |   4 -
 .../resources/camel-ignite-messaging-sink.json     |   7 -
 .../resources/camel-ignite-messaging-source.json   |   7 -
 ...amel-ignite-messaging-kafka-sink-connector.adoc |   3 +-
 ...el-ignite-messaging-kafka-source-connector.adoc |   3 +-
 .../CamelIgnitemessagingSinkConnectorConfig.java   |   4 -
 .../CamelIgnitemessagingSourceConnectorConfig.java |   4 -
 .../resources/camel-ignite-queue-sink.json         |   7 -
 .../camel-ignite-queue-kafka-sink-connector.adoc   |   3 +-
 .../CamelIgnitequeueSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-ignite-set-sink.json |   7 -
 .../camel-ignite-set-kafka-sink-connector.adoc     |   3 +-
 .../CamelIgnitesetSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-imap-sink.json   |   7 -
 .../src/generated/resources/camel-imap-source.json |  21 +-
 .../main/docs/camel-imap-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-imap-kafka-source-connector.adoc    |   5 +-
 .../imap/CamelImapSinkConnectorConfig.java         |   4 -
 .../imap/CamelImapSourceConnectorConfig.java       |  12 +-
 .../src/generated/resources/camel-imaps-sink.json  |   7 -
 .../generated/resources/camel-imaps-source.json    |  21 +-
 .../docs/camel-imaps-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-imaps-kafka-source-connector.adoc   |   5 +-
 .../imaps/CamelImapsSinkConnectorConfig.java       |   4 -
 .../imaps/CamelImapsSourceConnectorConfig.java     |  12 +-
 .../pom.xml                                        | 139 +++++++
 .../descriptors/connector-sink.properties          |   1 +
 .../descriptors/connector-source.properties        |   1 +
 .../resources/camel-infinispan-embedded-sink.json  | 238 ++++++++++++
 .../camel-infinispan-embedded-source.json          | 199 ++++++++++
 .../src/main/assembly/package.xml                  |  57 +++
 ...l-infinispan-embedded-kafka-sink-connector.adoc |  80 ++++
 ...infinispan-embedded-kafka-source-connector.adoc |  80 ++++
 ...CamelInfinispanembeddedSinkConnector.properties |  33 ++
 ...melInfinispanembeddedSourceConnector.properties |  33 ++
 .../CamelInfinispanembeddedSinkConnector.java      |  35 ++
 ...CamelInfinispanembeddedSinkConnectorConfig.java | 161 ++++++++
 .../CamelInfinispanembeddedSinkTask.java           |  39 ++
 .../CamelInfinispanembeddedSourceConnector.java    |  37 ++
 ...melInfinispanembeddedSourceConnectorConfig.java | 161 ++++++++
 .../CamelInfinispanembeddedSourceTask.java         |  39 ++
 .../src/main/resources/META-INF/LICENSE.txt        | 203 ++++++++++
 .../src/main/resources/META-INF/NOTICE.txt         |  11 +
 .../generated/resources/camel-infinispan-sink.json |  23 +-
 .../resources/camel-infinispan-source.json         |  65 +---
 .../camel-infinispan-kafka-sink-connector.adoc     |  19 +-
 .../camel-infinispan-kafka-source-connector.adoc   |  25 +-
 .../CamelInfinispanSinkConnectorConfig.java        |  20 +-
 .../CamelInfinispanSourceConnectorConfig.java      |  44 +--
 .../generated/resources/camel-influxdb-sink.json   |   7 -
 .../docs/camel-influxdb-kafka-sink-connector.adoc  |   3 +-
 .../influxdb/CamelInfluxdbSinkConnectorConfig.java |   4 -
 .../src/generated/resources/camel-iota-sink.json   |   7 -
 .../main/docs/camel-iota-kafka-sink-connector.adoc |   3 +-
 .../iota/CamelIotaSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-ipfs-sink.json   |   7 -
 .../main/docs/camel-ipfs-kafka-sink-connector.adoc |   3 +-
 .../ipfs/CamelIpfsSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-irc-sink.json    |   7 -
 .../src/generated/resources/camel-irc-source.json  |   7 -
 .../main/docs/camel-irc-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-irc-kafka-source-connector.adoc     |   3 +-
 .../irc/CamelIrcSinkConnectorConfig.java           |   4 -
 .../irc/CamelIrcSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-ironmq-sink.json |   7 -
 .../generated/resources/camel-ironmq-source.json   |   7 -
 .../docs/camel-ironmq-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-ironmq-kafka-source-connector.adoc  |   3 +-
 .../ironmq/CamelIronmqSinkConnectorConfig.java     |   4 -
 .../ironmq/CamelIronmqSourceConnectorConfig.java   |   4 -
 .../src/generated/resources/camel-jbpm-sink.json   |   7 -
 .../src/generated/resources/camel-jbpm-source.json |  14 +-
 .../main/docs/camel-jbpm-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-jbpm-kafka-source-connector.adoc    |   2 +-
 .../jbpm/CamelJbpmSinkConnectorConfig.java         |   4 -
 .../jbpm/CamelJbpmSourceConnectorConfig.java       |   8 +-
 .../generated/resources/camel-jclouds-sink.json    |   9 +-
 .../generated/resources/camel-jclouds-source.json  |   9 +-
 .../docs/camel-jclouds-kafka-sink-connector.adoc   |   7 +-
 .../docs/camel-jclouds-kafka-source-connector.adoc |   7 +-
 .../jclouds/CamelJcloudsSinkConnectorConfig.java   |   4 -
 .../jclouds/CamelJcloudsSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-jcr-sink.json    |   7 -
 .../src/generated/resources/camel-jcr-source.json  |   7 -
 .../main/docs/camel-jcr-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-jcr-kafka-source-connector.adoc     |   3 +-
 .../jcr/CamelJcrSinkConnectorConfig.java           |   4 -
 .../jcr/CamelJcrSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-jdbc-sink.json   |   7 -
 .../main/docs/camel-jdbc-kafka-sink-connector.adoc |   3 +-
 .../jdbc/CamelJdbcSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-jetty-source.json    |   7 -
 .../docs/camel-jetty-kafka-source-connector.adoc   |   3 +-
 .../jetty/CamelJettySourceConnectorConfig.java     |   4 -
 .../generated/resources/camel-jgroups-sink.json    |   7 -
 .../generated/resources/camel-jgroups-source.json  |   7 -
 .../docs/camel-jgroups-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-jgroups-kafka-source-connector.adoc |   3 +-
 .../jgroups/CamelJgroupsSinkConnectorConfig.java   |   4 -
 .../jgroups/CamelJgroupsSourceConnectorConfig.java |   4 -
 .../resources/camel-jgroups-raft-sink.json         |   7 -
 .../resources/camel-jgroups-raft-source.json       |   7 -
 .../camel-jgroups-raft-kafka-sink-connector.adoc   |   3 +-
 .../camel-jgroups-raft-kafka-source-connector.adoc |   3 +-
 .../CamelJgroupsraftSinkConnectorConfig.java       |   4 -
 .../CamelJgroupsraftSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-jing-sink.json   |   7 -
 .../main/docs/camel-jing-kafka-sink-connector.adoc |   3 +-
 .../jing/CamelJingSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-jira-sink.json   |   7 -
 .../src/generated/resources/camel-jira-source.json |   7 -
 .../main/docs/camel-jira-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-jira-kafka-source-connector.adoc    |   3 +-
 .../jira/CamelJiraSinkConnectorConfig.java         |   4 -
 .../jira/CamelJiraSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-jms-sink.json    |  13 +-
 .../src/generated/resources/camel-jms-source.json  |  21 +-
 .../main/docs/camel-jms-kafka-sink-connector.adoc  |   9 +-
 .../docs/camel-jms-kafka-source-connector.adoc     |   7 +-
 .../jms/CamelJmsSinkConnectorConfig.java           |  10 +-
 .../jms/CamelJmsSourceConnectorConfig.java         |  14 +-
 .../src/generated/resources/camel-jmx-source.json  |   7 -
 .../docs/camel-jmx-kafka-source-connector.adoc     |   3 +-
 .../jmx/CamelJmxSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-jolt-sink.json   |   7 -
 .../main/docs/camel-jolt-kafka-sink-connector.adoc |   3 +-
 .../jolt/CamelJoltSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-jooq-sink.json   |   7 -
 .../src/generated/resources/camel-jooq-source.json |   7 -
 .../main/docs/camel-jooq-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-jooq-kafka-source-connector.adoc    |   3 +-
 .../jooq/CamelJooqSinkConnectorConfig.java         |   4 -
 .../jooq/CamelJooqSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-jpa-sink.json    |   7 -
 .../src/generated/resources/camel-jpa-source.json  |   7 -
 .../main/docs/camel-jpa-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-jpa-kafka-source-connector.adoc     |   3 +-
 .../jpa/CamelJpaSinkConnectorConfig.java           |   4 -
 .../jpa/CamelJpaSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-jslt-sink.json   |  24 +-
 .../main/docs/camel-jslt-kafka-sink-connector.adoc |   7 +-
 .../jslt/CamelJsltSinkConnectorConfig.java         |  20 +-
 .../resources/camel-json-validator-sink.json       |   7 -
 .../camel-json-validator-kafka-sink-connector.adoc |   3 +-
 .../CamelJsonvalidatorSinkConnectorConfig.java     |   4 -
 .../generated/resources/camel-jsonata-sink.json    |  11 +-
 .../docs/camel-jsonata-kafka-sink-connector.adoc   |   9 +-
 .../jsonata/CamelJsonataSinkConnectorConfig.java   |   6 +-
 .../src/generated/resources/camel-jt400-sink.json  |   7 -
 .../generated/resources/camel-jt400-source.json    |   7 -
 .../docs/camel-jt400-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-jt400-kafka-source-connector.adoc   |   3 +-
 .../jt400/CamelJt400SinkConnectorConfig.java       |   4 -
 .../jt400/CamelJt400SourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-kafka-sink.json  |  15 +-
 .../generated/resources/camel-kafka-source.json    |  15 +-
 .../docs/camel-kafka-kafka-sink-connector.adoc     |   6 +-
 .../docs/camel-kafka-kafka-source-connector.adoc   |   6 +-
 .../kafka/CamelKafkaSinkConnectorConfig.java       |  10 +-
 .../kafka/CamelKafkaSourceConnectorConfig.java     |  10 +-
 connectors/camel-kamelet-kafka-connector/pom.xml   | 139 +++++++
 .../descriptors/connector-sink.properties          |   1 +
 .../descriptors/connector-source.properties        |   1 +
 .../generated/resources/camel-kamelet-sink.json    |  93 +++++
 .../generated/resources/camel-kamelet-source.json  |  75 ++++
 .../src/main/assembly/package.xml                  |  57 +++
 .../docs/camel-kamelet-kafka-sink-connector.adoc   |  63 +++
 .../docs/camel-kamelet-kafka-source-connector.adoc |  60 +++
 .../examples/CamelKameletSinkConnector.properties  |  33 ++
 .../CamelKameletSourceConnector.properties         |  33 ++
 .../kamelet/CamelKameletSinkConnector.java         |  35 ++
 .../kamelet/CamelKameletSinkConnectorConfig.java   |  90 +++++
 .../kamelet/CamelKameletSinkTask.java              |  39 ++
 .../kamelet/CamelKameletSourceConnector.java       |  35 ++
 .../kamelet/CamelKameletSourceConnectorConfig.java |  80 ++++
 .../kamelet/CamelKameletSourceTask.java            |  39 ++
 .../src/main/resources/META-INF/LICENSE.txt        | 203 ++++++++++
 .../src/main/resources/META-INF/NOTICE.txt         |  11 +
 .../camel-kubernetes-config-maps-sink.json         |   7 -
 ...ubernetes-config-maps-kafka-sink-connector.adoc |   3 +-
 ...melKubernetesconfigmapsSinkConnectorConfig.java |   4 -
 .../camel-kubernetes-custom-resources-sink.json    |   7 -
 .../camel-kubernetes-custom-resources-source.json  |   7 -
 ...etes-custom-resources-kafka-sink-connector.adoc |   3 +-
 ...es-custom-resources-kafka-source-connector.adoc |   3 +-
 ...bernetescustomresourcesSinkConnectorConfig.java |   4 -
 ...rnetescustomresourcesSourceConnectorConfig.java |   4 -
 .../camel-kubernetes-deployments-sink.json         |   7 -
 .../camel-kubernetes-deployments-source.json       |   7 -
 ...ubernetes-deployments-kafka-sink-connector.adoc |   3 +-
 ...ernetes-deployments-kafka-source-connector.adoc |   3 +-
 ...elKubernetesdeploymentsSinkConnectorConfig.java |   4 -
 ...KubernetesdeploymentsSourceConnectorConfig.java |   4 -
 .../resources/camel-kubernetes-hpa-sink.json       |   7 -
 .../resources/camel-kubernetes-hpa-source.json     |   7 -
 .../camel-kubernetes-hpa-kafka-sink-connector.adoc |   3 +-
 ...amel-kubernetes-hpa-kafka-source-connector.adoc |   3 +-
 .../CamelKuberneteshpaSinkConnectorConfig.java     |   4 -
 .../CamelKuberneteshpaSourceConnectorConfig.java   |   4 -
 .../resources/camel-kubernetes-job-sink.json       |   7 -
 .../resources/camel-kubernetes-job-source.json     |   7 -
 .../camel-kubernetes-job-kafka-sink-connector.adoc |   3 +-
 ...amel-kubernetes-job-kafka-source-connector.adoc |   3 +-
 .../CamelKubernetesjobSinkConnectorConfig.java     |   4 -
 .../CamelKubernetesjobSourceConnectorConfig.java   |   4 -
 .../camel-kubernetes-namespaces-sink.json          |   7 -
 .../camel-kubernetes-namespaces-source.json        |   7 -
 ...kubernetes-namespaces-kafka-sink-connector.adoc |   3 +-
 ...bernetes-namespaces-kafka-source-connector.adoc |   3 +-
 ...melKubernetesnamespacesSinkConnectorConfig.java |   4 -
 ...lKubernetesnamespacesSourceConnectorConfig.java |   4 -
 .../resources/camel-kubernetes-nodes-sink.json     |   7 -
 .../resources/camel-kubernetes-nodes-source.json   |   7 -
 ...amel-kubernetes-nodes-kafka-sink-connector.adoc |   3 +-
 ...el-kubernetes-nodes-kafka-source-connector.adoc |   3 +-
 .../CamelKubernetesnodesSinkConnectorConfig.java   |   4 -
 .../CamelKubernetesnodesSourceConnectorConfig.java |   4 -
 ...-kubernetes-persistent-volumes-claims-sink.json |   7 -
 ...istent-volumes-claims-kafka-sink-connector.adoc |   3 +-
 ...persistentvolumesclaimsSinkConnectorConfig.java |   4 -
 .../camel-kubernetes-persistent-volumes-sink.json  |   7 -
 ...es-persistent-volumes-kafka-sink-connector.adoc |   3 +-
 ...rnetespersistentvolumesSinkConnectorConfig.java |   4 -
 .../resources/camel-kubernetes-pods-sink.json      |   7 -
 .../resources/camel-kubernetes-pods-source.json    |   7 -
 ...camel-kubernetes-pods-kafka-sink-connector.adoc |   3 +-
 ...mel-kubernetes-pods-kafka-source-connector.adoc |   3 +-
 .../CamelKubernetespodsSinkConnectorConfig.java    |   4 -
 .../CamelKubernetespodsSourceConnectorConfig.java  |   4 -
 ...el-kubernetes-replication-controllers-sink.json |   7 -
 ...-kubernetes-replication-controllers-source.json |   7 -
 ...plication-controllers-kafka-sink-connector.adoc |   3 +-
 ...ication-controllers-kafka-source-connector.adoc |   3 +-
 ...sreplicationcontrollersSinkConnectorConfig.java |   4 -
 ...eplicationcontrollersSourceConnectorConfig.java |   4 -
 .../camel-kubernetes-resources-quota-sink.json     |   7 -
 ...netes-resources-quota-kafka-sink-connector.adoc |   3 +-
 ...ubernetesresourcesquotaSinkConnectorConfig.java |   4 -
 .../resources/camel-kubernetes-secrets-sink.json   |   7 -
 ...el-kubernetes-secrets-kafka-sink-connector.adoc |   3 +-
 .../CamelKubernetessecretsSinkConnectorConfig.java |   4 -
 .../camel-kubernetes-service-accounts-sink.json    |   7 -
 ...etes-service-accounts-kafka-sink-connector.adoc |   3 +-
 ...bernetesserviceaccountsSinkConnectorConfig.java |   4 -
 .../resources/camel-kubernetes-services-sink.json  |   7 -
 .../camel-kubernetes-services-source.json          |   7 -
 ...l-kubernetes-services-kafka-sink-connector.adoc |   3 +-
 ...kubernetes-services-kafka-source-connector.adoc |   3 +-
 ...CamelKubernetesservicesSinkConnectorConfig.java |   4 -
 ...melKubernetesservicesSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-kudu-sink.json   |   7 -
 .../main/docs/camel-kudu-kafka-sink-connector.adoc |   3 +-
 .../kudu/CamelKuduSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-language-sink.json   |   7 -
 .../docs/camel-language-kafka-sink-connector.adoc  |   3 +-
 .../language/CamelLanguageSinkConnectorConfig.java |   4 -
 .../src/generated/resources/camel-ldap-sink.json   |   7 -
 .../main/docs/camel-ldap-kafka-sink-connector.adoc |   3 +-
 .../ldap/CamelLdapSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-ldif-sink.json   |   7 -
 .../main/docs/camel-ldif-kafka-sink-connector.adoc |   3 +-
 .../ldif/CamelLdifSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-log-sink.json    |   7 -
 .../main/docs/camel-log-kafka-sink-connector.adoc  |   3 +-
 .../log/CamelLogSinkConnectorConfig.java           |   4 -
 .../src/generated/resources/camel-lpr-sink.json    |   7 -
 .../main/docs/camel-lpr-kafka-sink-connector.adoc  |   3 +-
 .../lpr/CamelLprSinkConnectorConfig.java           |   4 -
 .../src/generated/resources/camel-lucene-sink.json |   7 -
 .../docs/camel-lucene-kafka-sink-connector.adoc    |   3 +-
 .../lucene/CamelLuceneSinkConnectorConfig.java     |   4 -
 .../resources/camel-lumberjack-source.json         |   7 -
 .../camel-lumberjack-kafka-source-connector.adoc   |   3 +-
 .../CamelLumberjackSourceConnectorConfig.java      |   4 -
 .../generated/resources/camel-master-source.json   |   7 -
 .../docs/camel-master-kafka-source-connector.adoc  |   3 +-
 .../master/CamelMasterSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-metrics-sink.json    |   7 -
 .../docs/camel-metrics-kafka-sink-connector.adoc   |   3 +-
 .../metrics/CamelMetricsSinkConnectorConfig.java   |   4 -
 .../generated/resources/camel-micrometer-sink.json |   7 -
 .../camel-micrometer-kafka-sink-connector.adoc     |   3 +-
 .../CamelMicrometerSinkConnectorConfig.java        |   4 -
 .../resources/camel-microprofile-metrics-sink.json |   7 -
 ...-microprofile-metrics-kafka-sink-connector.adoc |   3 +-
 ...amelMicroprofilemetricsSinkConnectorConfig.java |   4 -
 .../resources/camel-milo-client-sink.json          |  47 ++-
 .../resources/camel-milo-client-source.json        |  47 ++-
 .../camel-milo-client-kafka-sink-connector.adoc    |   8 +-
 .../camel-milo-client-kafka-source-connector.adoc  |   8 +-
 .../CamelMiloclientSinkConnectorConfig.java        |  24 +-
 .../CamelMiloclientSourceConnectorConfig.java      |  24 +-
 .../resources/camel-milo-server-sink.json          |   7 -
 .../resources/camel-milo-server-source.json        |   7 -
 .../camel-milo-server-kafka-sink-connector.adoc    |   3 +-
 .../camel-milo-server-kafka-source-connector.adoc  |   3 +-
 .../CamelMiloserverSinkConnectorConfig.java        |   4 -
 .../CamelMiloserverSourceConnectorConfig.java      |   4 -
 .../src/generated/resources/camel-mina-sink.json   |   7 -
 .../src/generated/resources/camel-mina-source.json |   7 -
 .../main/docs/camel-mina-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-mina-kafka-source-connector.adoc    |   3 +-
 .../mina/CamelMinaSinkConnectorConfig.java         |   4 -
 .../mina/CamelMinaSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-minio-sink.json  |   7 -
 .../generated/resources/camel-minio-source.json    |   7 -
 .../docs/camel-minio-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-minio-kafka-source-connector.adoc   |   3 +-
 .../minio/CamelMinioSinkConnectorConfig.java       |   4 -
 .../minio/CamelMinioSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-mllp-sink.json   |   7 -
 .../src/generated/resources/camel-mllp-source.json |   7 -
 .../main/docs/camel-mllp-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-mllp-kafka-source-connector.adoc    |   3 +-
 .../mllp/CamelMllpSinkConnectorConfig.java         |   4 -
 .../mllp/CamelMllpSourceConnectorConfig.java       |   4 -
 .../resources/camel-mongodb-gridfs-sink.json       |   7 -
 .../resources/camel-mongodb-gridfs-source.json     |   7 -
 .../camel-mongodb-gridfs-kafka-sink-connector.adoc |   3 +-
 ...amel-mongodb-gridfs-kafka-source-connector.adoc |   3 +-
 .../CamelMongodbgridfsSinkConnectorConfig.java     |   4 -
 .../CamelMongodbgridfsSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-mongodb-sink.json    |   7 -
 .../generated/resources/camel-mongodb-source.json  |   7 -
 .../docs/camel-mongodb-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-mongodb-kafka-source-connector.adoc |   3 +-
 .../mongodb/CamelMongodbSinkConnectorConfig.java   |   4 -
 .../mongodb/CamelMongodbSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-msv-sink.json    |   7 -
 .../main/docs/camel-msv-kafka-sink-connector.adoc  |   3 +-
 .../msv/CamelMsvSinkConnectorConfig.java           |   4 -
 .../generated/resources/camel-mustache-sink.json   |   7 -
 .../docs/camel-mustache-kafka-sink-connector.adoc  |   3 +-
 .../mustache/CamelMustacheSinkConnectorConfig.java |   4 -
 .../src/generated/resources/camel-mvel-sink.json   |   7 -
 .../main/docs/camel-mvel-kafka-sink-connector.adoc |   3 +-
 .../mvel/CamelMvelSinkConnectorConfig.java         |   4 -
 .../resources/camel-mybatis-bean-sink.json         |   7 -
 .../camel-mybatis-bean-kafka-sink-connector.adoc   |   3 +-
 .../CamelMybatisbeanSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-mybatis-sink.json    |   7 -
 .../generated/resources/camel-mybatis-source.json  |   7 -
 .../docs/camel-mybatis-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-mybatis-kafka-source-connector.adoc |   3 +-
 .../mybatis/CamelMybatisSinkConnectorConfig.java   |   4 -
 .../mybatis/CamelMybatisSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-nagios-sink.json |   7 -
 .../docs/camel-nagios-kafka-sink-connector.adoc    |   3 +-
 .../nagios/CamelNagiosSinkConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-nats-sink.json   |  14 +-
 .../src/generated/resources/camel-nats-source.json |   7 -
 .../main/docs/camel-nats-kafka-sink-connector.adoc |   2 +-
 .../docs/camel-nats-kafka-source-connector.adoc    |   3 +-
 .../nats/CamelNatsSinkConnectorConfig.java         |   8 +-
 .../nats/CamelNatsSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-netty-http-sink.json |   2 +-
 .../resources/camel-netty-http-source.json         |   2 +-
 .../camel-netty-http-kafka-sink-connector.adoc     |   2 +-
 .../camel-netty-http-kafka-source-connector.adoc   |   2 +-
 .../CamelNettyhttpSinkConnectorConfig.java         |   2 +-
 .../CamelNettyhttpSourceConnectorConfig.java       |   2 +-
 .../src/generated/resources/camel-netty-sink.json  |   2 +-
 .../generated/resources/camel-netty-source.json    |   2 +-
 .../docs/camel-netty-kafka-sink-connector.adoc     |   2 +-
 .../docs/camel-netty-kafka-source-connector.adoc   |   2 +-
 .../netty/CamelNettySinkConnectorConfig.java       |   2 +-
 .../netty/CamelNettySourceConnectorConfig.java     |   2 +-
 .../generated/resources/camel-nitrite-sink.json    |   7 -
 .../generated/resources/camel-nitrite-source.json  |   7 -
 .../docs/camel-nitrite-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-nitrite-kafka-source-connector.adoc |   3 +-
 .../nitrite/CamelNitriteSinkConnectorConfig.java   |   4 -
 .../nitrite/CamelNitriteSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-nsq-sink.json    |   7 -
 .../src/generated/resources/camel-nsq-source.json  |   7 -
 .../main/docs/camel-nsq-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-nsq-kafka-source-connector.adoc     |   3 +-
 .../nsq/CamelNsqSinkConnectorConfig.java           |   4 -
 .../nsq/CamelNsqSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-oaipmh-sink.json |   7 -
 .../generated/resources/camel-oaipmh-source.json   |   7 -
 .../docs/camel-oaipmh-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-oaipmh-kafka-source-connector.adoc  |   3 +-
 .../oaipmh/CamelOaipmhSinkConnectorConfig.java     |   4 -
 .../oaipmh/CamelOaipmhSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-olingo2-sink.json    |   7 -
 .../generated/resources/camel-olingo2-source.json  |   7 -
 .../docs/camel-olingo2-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-olingo2-kafka-source-connector.adoc |   3 +-
 .../olingo2/CamelOlingo2SinkConnectorConfig.java   |   4 -
 .../olingo2/CamelOlingo2SourceConnectorConfig.java |   4 -
 .../generated/resources/camel-olingo4-sink.json    |   7 -
 .../generated/resources/camel-olingo4-source.json  |   7 -
 .../docs/camel-olingo4-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-olingo4-kafka-source-connector.adoc |   3 +-
 .../olingo4/CamelOlingo4SinkConnectorConfig.java   |   4 -
 .../olingo4/CamelOlingo4SourceConnectorConfig.java |   4 -
 .../camel-openshift-build-configs-sink.json        |   7 -
 ...enshift-build-configs-kafka-sink-connector.adoc |   3 +-
 ...elOpenshiftbuildconfigsSinkConnectorConfig.java |   4 -
 .../resources/camel-openshift-builds-sink.json     |   7 -
 ...amel-openshift-builds-kafka-sink-connector.adoc |   3 +-
 .../CamelOpenshiftbuildsSinkConnectorConfig.java   |   4 -
 .../resources/camel-openstack-cinder-sink.json     |   7 -
 ...amel-openstack-cinder-kafka-sink-connector.adoc |   3 +-
 .../CamelOpenstackcinderSinkConnectorConfig.java   |   4 -
 .../resources/camel-openstack-glance-sink.json     |   7 -
 ...amel-openstack-glance-kafka-sink-connector.adoc |   3 +-
 .../CamelOpenstackglanceSinkConnectorConfig.java   |   4 -
 .../resources/camel-openstack-keystone-sink.json   |   7 -
 ...el-openstack-keystone-kafka-sink-connector.adoc |   3 +-
 .../CamelOpenstackkeystoneSinkConnectorConfig.java |   4 -
 .../resources/camel-openstack-neutron-sink.json    |   7 -
 ...mel-openstack-neutron-kafka-sink-connector.adoc |   3 +-
 .../CamelOpenstackneutronSinkConnectorConfig.java  |   4 -
 .../resources/camel-openstack-nova-sink.json       |   7 -
 .../camel-openstack-nova-kafka-sink-connector.adoc |   3 +-
 .../CamelOpenstacknovaSinkConnectorConfig.java     |   4 -
 .../resources/camel-openstack-swift-sink.json      |   7 -
 ...camel-openstack-swift-kafka-sink-connector.adoc |   3 +-
 .../CamelOpenstackswiftSinkConnectorConfig.java    |   4 -
 .../resources/camel-optaplanner-sink.json          |   7 -
 .../resources/camel-optaplanner-source.json        |   7 -
 .../camel-optaplanner-kafka-sink-connector.adoc    |   3 +-
 .../camel-optaplanner-kafka-source-connector.adoc  |   3 +-
 .../CamelOptaplannerSinkConnectorConfig.java       |   4 -
 .../CamelOptaplannerSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-paho-sink.json   |   7 -
 .../src/generated/resources/camel-paho-source.json |   7 -
 .../main/docs/camel-paho-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-paho-kafka-source-connector.adoc    |   3 +-
 .../paho/CamelPahoSinkConnectorConfig.java         |   4 -
 .../paho/CamelPahoSourceConnectorConfig.java       |   4 -
 .../camel-paho-mqtt5-kafka-connector/pom.xml       | 139 +++++++
 .../descriptors/connector-sink.properties          |   1 +
 .../descriptors/connector-source.properties        |   1 +
 .../generated/resources/camel-paho-mqtt5-sink.json | 406 ++++++++++++++++++++
 .../resources/camel-paho-mqtt5-source.json         | 423 +++++++++++++++++++++
 .../src/main/assembly/package.xml                  |  57 +++
 .../camel-paho-mqtt5-kafka-sink-connector.adoc     | 110 ++++++
 .../camel-paho-mqtt5-kafka-source-connector.adoc   | 112 ++++++
 .../CamelPahomqtt5SinkConnector.properties         |  33 ++
 .../CamelPahomqtt5SourceConnector.properties       |  33 ++
 .../pahomqtt5/CamelPahomqtt5SinkConnector.java     |  35 ++
 .../CamelPahomqtt5SinkConnectorConfig.java         | 280 ++++++++++++++
 .../pahomqtt5/CamelPahomqtt5SinkTask.java          |  39 ++
 .../pahomqtt5/CamelPahomqtt5SourceConnector.java   |  35 ++
 .../CamelPahomqtt5SourceConnectorConfig.java       | 288 ++++++++++++++
 .../pahomqtt5/CamelPahomqtt5SourceTask.java        |  39 ++
 .../src/main/resources/META-INF/LICENSE.txt        | 203 ++++++++++
 .../src/main/resources/META-INF/NOTICE.txt         |  11 +
 .../src/generated/resources/camel-pdf-sink.json    |   7 -
 .../main/docs/camel-pdf-kafka-sink-connector.adoc  |   3 +-
 .../pdf/CamelPdfSinkConnectorConfig.java           |   4 -
 .../camel-pg-replication-slot-source.json          |   7 -
 ...pg-replication-slot-kafka-source-connector.adoc |   3 +-
 ...amelPgreplicationslotSourceConnectorConfig.java |   4 -
 .../generated/resources/camel-pgevent-sink.json    |   7 -
 .../generated/resources/camel-pgevent-source.json  |   7 -
 .../docs/camel-pgevent-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-pgevent-kafka-source-connector.adoc |   3 +-
 .../pgevent/CamelPgeventSinkConnectorConfig.java   |   4 -
 .../pgevent/CamelPgeventSourceConnectorConfig.java |   4 -
 .../resources/camel-platform-http-source.json      |   7 -
 ...camel-platform-http-kafka-source-connector.adoc |   3 +-
 .../CamelPlatformhttpSourceConnectorConfig.java    |   4 -
 .../src/generated/resources/camel-pop3-sink.json   |   7 -
 .../src/generated/resources/camel-pop3-source.json |  21 +-
 .../main/docs/camel-pop3-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-pop3-kafka-source-connector.adoc    |   5 +-
 .../pop3/CamelPop3SinkConnectorConfig.java         |   4 -
 .../pop3/CamelPop3SourceConnectorConfig.java       |  12 +-
 .../src/generated/resources/camel-pop3s-sink.json  |   7 -
 .../generated/resources/camel-pop3s-source.json    |  21 +-
 .../docs/camel-pop3s-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-pop3s-kafka-source-connector.adoc   |   5 +-
 .../pop3s/CamelPop3sSinkConnectorConfig.java       |   4 -
 .../pop3s/CamelPop3sSourceConnectorConfig.java     |  12 +-
 .../src/generated/resources/camel-pubnub-sink.json |   7 -
 .../generated/resources/camel-pubnub-source.json   |   7 -
 .../docs/camel-pubnub-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-pubnub-kafka-source-connector.adoc  |   3 +-
 .../pubnub/CamelPubnubSinkConnectorConfig.java     |   4 -
 .../pubnub/CamelPubnubSourceConnectorConfig.java   |   4 -
 .../src/generated/resources/camel-pulsar-sink.json |   7 -
 .../generated/resources/camel-pulsar-source.json   |   7 -
 .../docs/camel-pulsar-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-pulsar-kafka-source-connector.adoc  |   3 +-
 .../pulsar/CamelPulsarSinkConnectorConfig.java     |   4 -
 .../pulsar/CamelPulsarSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-quartz-source.json   |   7 -
 .../docs/camel-quartz-kafka-source-connector.adoc  |   3 +-
 .../quartz/CamelQuartzSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-quickfix-sink.json   |   7 -
 .../generated/resources/camel-quickfix-source.json |   7 -
 .../docs/camel-quickfix-kafka-sink-connector.adoc  |   3 +-
 .../camel-quickfix-kafka-source-connector.adoc     |   3 +-
 .../quickfix/CamelQuickfixSinkConnectorConfig.java |   4 -
 .../CamelQuickfixSourceConnectorConfig.java        |   4 -
 .../generated/resources/camel-rabbitmq-sink.json   |  21 +-
 .../generated/resources/camel-rabbitmq-source.json |  21 +-
 .../docs/camel-rabbitmq-kafka-sink-connector.adoc  |   5 +-
 .../camel-rabbitmq-kafka-source-connector.adoc     |   5 +-
 .../rabbitmq/CamelRabbitmqSinkConnectorConfig.java |  12 +-
 .../CamelRabbitmqSourceConnectorConfig.java        |  12 +-
 .../resources/camel-reactive-streams-sink.json     |   7 -
 .../resources/camel-reactive-streams-source.json   |   7 -
 ...amel-reactive-streams-kafka-sink-connector.adoc |   3 +-
 ...el-reactive-streams-kafka-source-connector.adoc |   3 +-
 .../CamelReactivestreamsSinkConnectorConfig.java   |   4 -
 .../CamelReactivestreamsSourceConnectorConfig.java |   4 -
 .../generated/resources/camel-rest-api-source.json |   7 -
 .../camel-rest-api-kafka-source-connector.adoc     |   3 +-
 .../restapi/CamelRestapiSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-rest-sink.json   |   7 -
 .../src/generated/resources/camel-rest-source.json |   7 -
 .../main/docs/camel-rest-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-rest-kafka-source-connector.adoc    |   3 +-
 .../rest/CamelRestSinkConnectorConfig.java         |   4 -
 .../rest/CamelRestSourceConnectorConfig.java       |   4 -
 .../resources/camel-rest-openapi-sink.json         |   7 -
 .../camel-rest-openapi-kafka-sink-connector.adoc   |   3 +-
 .../CamelRestopenapiSinkConnectorConfig.java       |   4 -
 .../resources/camel-rest-swagger-sink.json         |   7 -
 .../camel-rest-swagger-kafka-sink-connector.adoc   |   3 +-
 .../CamelRestswaggerSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-resteasy-sink.json   |   7 -
 .../generated/resources/camel-resteasy-source.json |   7 -
 .../docs/camel-resteasy-kafka-sink-connector.adoc  |   3 +-
 .../camel-resteasy-kafka-source-connector.adoc     |   3 +-
 .../resteasy/CamelResteasySinkConnectorConfig.java |   4 -
 .../CamelResteasySourceConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-rss-source.json  |   7 -
 .../docs/camel-rss-kafka-source-connector.adoc     |   3 +-
 .../rss/CamelRssSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-saga-sink.json   |   7 -
 .../main/docs/camel-saga-kafka-sink-connector.adoc |   3 +-
 .../saga/CamelSagaSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-salesforce-sink.json |  87 ++++-
 .../resources/camel-salesforce-source.json         |  67 +++-
 .../camel-salesforce-kafka-sink-connector.adoc     |  15 +-
 .../camel-salesforce-kafka-source-connector.adoc   |  13 +-
 .../CamelSalesforceSinkConnectorConfig.java        |  46 ++-
 .../CamelSalesforceSourceConnectorConfig.java      |  44 ++-
 .../resources/camel-sap-netweaver-sink.json        |   7 -
 .../camel-sap-netweaver-kafka-sink-connector.adoc  |   3 +-
 .../CamelSapnetweaverSinkConnectorConfig.java      |   4 -
 .../resources/camel-scheduler-source.json          |   2 +-
 .../camel-scheduler-kafka-source-connector.adoc    |   2 +-
 .../CamelSchedulerSourceConnectorConfig.java       |   2 +-
 .../generated/resources/camel-schematron-sink.json |   7 -
 .../camel-schematron-kafka-sink-connector.adoc     |   3 +-
 .../CamelSchematronSinkConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-scp-sink.json    |   2 +-
 .../main/docs/camel-scp-kafka-sink-connector.adoc  |   2 +-
 .../scp/CamelScpSinkConnectorConfig.java           |   2 +-
 .../src/generated/resources/camel-seda-sink.json   |   7 -
 .../src/generated/resources/camel-seda-source.json |   7 -
 .../main/docs/camel-seda-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-seda-kafka-source-connector.adoc    |   3 +-
 .../seda/CamelSedaSinkConnectorConfig.java         |   4 -
 .../seda/CamelSedaSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-service-source.json  |   7 -
 .../docs/camel-service-kafka-source-connector.adoc |   3 +-
 .../service/CamelServiceSourceConnectorConfig.java |   4 -
 .../generated/resources/camel-servicenow-sink.json |   7 -
 .../camel-servicenow-kafka-sink-connector.adoc     |   3 +-
 .../CamelServicenowSinkConnectorConfig.java        |   4 -
 .../generated/resources/camel-servlet-source.json  |   7 -
 .../docs/camel-servlet-kafka-source-connector.adoc |   3 +-
 .../servlet/CamelServletSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-sftp-sink.json   |   2 +-
 .../src/generated/resources/camel-sftp-source.json |  14 +-
 .../main/docs/camel-sftp-kafka-sink-connector.adoc |   2 +-
 .../docs/camel-sftp-kafka-source-connector.adoc    |   6 +-
 .../sftp/CamelSftpSinkConnectorConfig.java         |   2 +-
 .../sftp/CamelSftpSourceConnectorConfig.java       |  10 +-
 .../src/generated/resources/camel-sip-sink.json    |   7 -
 .../src/generated/resources/camel-sip-source.json  |   9 +-
 .../main/docs/camel-sip-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-sip-kafka-source-connector.adoc     |   5 +-
 .../sip/CamelSipSinkConnectorConfig.java           |   4 -
 .../sip/CamelSipSourceConnectorConfig.java         |   6 +-
 .../src/generated/resources/camel-sips-sink.json   |   7 -
 .../src/generated/resources/camel-sips-source.json |   9 +-
 .../main/docs/camel-sips-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-sips-kafka-source-connector.adoc    |   5 +-
 .../sips/CamelSipsSinkConnectorConfig.java         |   4 -
 .../sips/CamelSipsSourceConnectorConfig.java       |   6 +-
 .../src/generated/resources/camel-sjms-sink.json   | 231 ++++++-----
 .../src/generated/resources/camel-sjms-source.json | 247 +++++-------
 .../main/docs/camel-sjms-kafka-sink-connector.adoc |  46 +--
 .../docs/camel-sjms-kafka-source-connector.adoc    |  48 +--
 .../sjms/CamelSjmsSinkConnectorConfig.java         | 170 +++++----
 .../sjms/CamelSjmsSourceConnectorConfig.java       | 178 ++++-----
 .../src/generated/resources/camel-sjms2-sink.json  | 231 ++++++-----
 .../generated/resources/camel-sjms2-source.json    | 251 +++++-------
 .../docs/camel-sjms2-kafka-sink-connector.adoc     |  46 +--
 .../docs/camel-sjms2-kafka-source-connector.adoc   |  48 +--
 .../sjms2/CamelSjms2SinkConnectorConfig.java       | 170 +++++----
 .../sjms2/CamelSjms2SourceConnectorConfig.java     | 178 ++++-----
 .../src/generated/resources/camel-slack-sink.json  |   7 -
 .../generated/resources/camel-slack-source.json    |   7 -
 .../docs/camel-slack-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-slack-kafka-source-connector.adoc   |   3 +-
 .../slack/CamelSlackSinkConnectorConfig.java       |   4 -
 .../slack/CamelSlackSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-smpp-sink.json   |   7 -
 .../src/generated/resources/camel-smpp-source.json |   7 -
 .../main/docs/camel-smpp-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-smpp-kafka-source-connector.adoc    |   3 +-
 .../smpp/CamelSmppSinkConnectorConfig.java         |   4 -
 .../smpp/CamelSmppSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-smpps-sink.json  |   7 -
 .../generated/resources/camel-smpps-source.json    |   7 -
 .../docs/camel-smpps-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-smpps-kafka-source-connector.adoc   |   3 +-
 .../smpps/CamelSmppsSinkConnectorConfig.java       |   4 -
 .../smpps/CamelSmppsSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-smtp-sink.json   |   7 -
 .../src/generated/resources/camel-smtp-source.json |  21 +-
 .../main/docs/camel-smtp-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-smtp-kafka-source-connector.adoc    |   5 +-
 .../smtp/CamelSmtpSinkConnectorConfig.java         |   4 -
 .../smtp/CamelSmtpSourceConnectorConfig.java       |  12 +-
 .../src/generated/resources/camel-smtps-sink.json  |   7 -
 .../generated/resources/camel-smtps-source.json    |  21 +-
 .../docs/camel-smtps-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-smtps-kafka-source-connector.adoc   |   5 +-
 .../smtps/CamelSmtpsSinkConnectorConfig.java       |   4 -
 .../smtps/CamelSmtpsSourceConnectorConfig.java     |  12 +-
 .../src/generated/resources/camel-snmp-sink.json   |   7 -
 .../src/generated/resources/camel-snmp-source.json |   7 -
 .../main/docs/camel-snmp-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-snmp-kafka-source-connector.adoc    |   3 +-
 .../snmp/CamelSnmpSinkConnectorConfig.java         |   4 -
 .../snmp/CamelSnmpSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-solr-sink.json   |   7 -
 .../main/docs/camel-solr-kafka-sink-connector.adoc |   3 +-
 .../solr/CamelSolrSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-solrCloud-sink.json  |   7 -
 .../docs/camel-solrCloud-kafka-sink-connector.adoc |   3 +-
 .../CamelSolrcloudSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-solrs-sink.json  |   7 -
 .../docs/camel-solrs-kafka-sink-connector.adoc     |   3 +-
 .../solrs/CamelSolrsSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-soroush-sink.json    |   7 -
 .../generated/resources/camel-soroush-source.json  |   7 -
 .../docs/camel-soroush-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-soroush-kafka-source-connector.adoc |   3 +-
 .../soroush/CamelSoroushSinkConnectorConfig.java   |   4 -
 .../soroush/CamelSoroushSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-spark-sink.json  |   7 -
 .../docs/camel-spark-kafka-sink-connector.adoc     |   3 +-
 .../spark/CamelSparkSinkConnectorConfig.java       |   4 -
 .../generated/resources/camel-splunk-hec-sink.json |   7 -
 .../camel-splunk-hec-kafka-sink-connector.adoc     |   3 +-
 .../CamelSplunkhecSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-splunk-sink.json |   7 -
 .../generated/resources/camel-splunk-source.json   |   7 -
 .../docs/camel-splunk-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-splunk-kafka-source-connector.adoc  |   3 +-
 .../splunk/CamelSplunkSinkConnectorConfig.java     |   4 -
 .../splunk/CamelSplunkSourceConnectorConfig.java   |   4 -
 .../resources/camel-spring-batch-sink.json         |   7 -
 .../camel-spring-batch-kafka-sink-connector.adoc   |   3 +-
 .../CamelSpringbatchSinkConnectorConfig.java       |   4 -
 .../resources/camel-spring-event-sink.json         |   7 -
 .../resources/camel-spring-event-source.json       |   7 -
 .../camel-spring-event-kafka-sink-connector.adoc   |   3 +-
 .../camel-spring-event-kafka-source-connector.adoc |   3 +-
 .../CamelSpringeventSinkConnectorConfig.java       |   4 -
 .../CamelSpringeventSourceConnectorConfig.java     |   4 -
 .../resources/camel-spring-integration-sink.json   |   7 -
 .../resources/camel-spring-integration-source.json |   7 -
 ...el-spring-integration-kafka-sink-connector.adoc |   3 +-
 ...-spring-integration-kafka-source-connector.adoc |   3 +-
 .../CamelSpringintegrationSinkConnectorConfig.java |   4 -
 ...amelSpringintegrationSourceConnectorConfig.java |   4 -
 .../resources/camel-spring-ldap-sink.json          |   7 -
 .../camel-spring-ldap-kafka-sink-connector.adoc    |   3 +-
 .../CamelSpringldapSinkConnectorConfig.java        |   4 -
 .../camel-spring-rabbitmq-kafka-connector/pom.xml  | 139 +++++++
 .../descriptors/connector-sink.properties          |   1 +
 .../descriptors/connector-source.properties        |   1 +
 .../resources/camel-spring-rabbitmq-sink.json      | 149 ++++++++
 .../resources/camel-spring-rabbitmq-source.json    | 319 ++++++++++++++++
 .../src/main/assembly/package.xml                  |  57 +++
 ...camel-spring-rabbitmq-kafka-sink-connector.adoc |  72 ++++
 ...mel-spring-rabbitmq-kafka-source-connector.adoc |  94 +++++
 .../CamelSpringrabbitmqSinkConnector.properties    |  33 ++
 .../CamelSpringrabbitmqSourceConnector.properties  |  33 ++
 .../CamelSpringrabbitmqSinkConnector.java          |  35 ++
 .../CamelSpringrabbitmqSinkConnectorConfig.java    | 129 +++++++
 .../CamelSpringrabbitmqSinkTask.java               |  39 ++
 .../CamelSpringrabbitmqSourceConnector.java        |  35 ++
 .../CamelSpringrabbitmqSourceConnectorConfig.java  | 217 +++++++++++
 .../CamelSpringrabbitmqSourceTask.java             |  39 ++
 .../src/main/resources/META-INF/LICENSE.txt        | 203 ++++++++++
 .../src/main/resources/META-INF/NOTICE.txt         |  11 +
 .../resources/camel-spring-redis-sink.json         |   7 +-
 .../resources/camel-spring-redis-source.json       |   7 +-
 .../camel-spring-redis-kafka-sink-connector.adoc   |   2 +-
 .../camel-spring-redis-kafka-source-connector.adoc |   2 +-
 .../CamelSpringredisSinkConnectorConfig.java       |   8 +-
 .../CamelSpringredisSourceConnectorConfig.java     |   8 +-
 .../generated/resources/camel-spring-ws-sink.json  |   7 -
 .../resources/camel-spring-ws-source.json          |   7 -
 .../docs/camel-spring-ws-kafka-sink-connector.adoc |   3 +-
 .../camel-spring-ws-kafka-source-connector.adoc    |   3 +-
 .../springws/CamelSpringwsSinkConnectorConfig.java |   4 -
 .../CamelSpringwsSourceConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-sql-sink.json    |   9 +-
 .../src/generated/resources/camel-sql-source.json  |   9 +-
 .../main/docs/camel-sql-kafka-sink-connector.adoc  |   5 +-
 .../docs/camel-sql-kafka-source-connector.adoc     |   5 +-
 .../sql/CamelSqlSinkConnectorConfig.java           |   6 +-
 .../sql/CamelSqlSourceConnectorConfig.java         |   6 +-
 .../generated/resources/camel-sql-stored-sink.json |   7 -
 .../camel-sql-stored-kafka-sink-connector.adoc     |   3 +-
 .../CamelSqlstoredSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-ssh-sink.json    |   7 -
 .../src/generated/resources/camel-ssh-source.json  |   7 -
 .../main/docs/camel-ssh-kafka-sink-connector.adoc  |   3 +-
 .../docs/camel-ssh-kafka-source-connector.adoc     |   3 +-
 .../ssh/CamelSshSinkConnectorConfig.java           |   4 -
 .../ssh/CamelSshSourceConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-stax-sink.json   |   7 -
 .../main/docs/camel-stax-kafka-sink-connector.adoc |   3 +-
 .../stax/CamelStaxSinkConnectorConfig.java         |   4 -
 connectors/camel-stitch-kafka-connector/pom.xml    | 139 +++++++
 .../descriptors/connector-sink.properties          |   1 +
 .../src/generated/resources/camel-stitch-sink.json | 140 +++++++
 .../src/main/assembly/package.xml                  |  57 +++
 .../docs/camel-stitch-kafka-sink-connector.adoc    |  70 ++++
 .../examples/CamelStitchSinkConnector.properties   |  35 ++
 .../stitch/CamelStitchSinkConnector.java           |  35 ++
 .../stitch/CamelStitchSinkConnectorConfig.java     | 118 ++++++
 .../kafkaconnector/stitch/CamelStitchSinkTask.java |  39 ++
 .../src/main/resources/META-INF/LICENSE.txt        | 203 ++++++++++
 .../src/main/resources/META-INF/NOTICE.txt         |  11 +
 .../src/generated/resources/camel-stomp-sink.json  |   7 -
 .../generated/resources/camel-stomp-source.json    |   7 -
 .../docs/camel-stomp-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-stomp-kafka-source-connector.adoc   |   3 +-
 .../stomp/CamelStompSinkConnectorConfig.java       |   4 -
 .../stomp/CamelStompSourceConnectorConfig.java     |   4 -
 .../src/generated/resources/camel-stream-sink.json |   7 -
 .../generated/resources/camel-stream-source.json   |   7 -
 .../docs/camel-stream-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-stream-kafka-source-connector.adoc  |   3 +-
 .../stream/CamelStreamSinkConnectorConfig.java     |   4 -
 .../stream/CamelStreamSourceConnectorConfig.java   |   4 -
 .../resources/camel-string-template-sink.json      |   7 -
 ...camel-string-template-kafka-sink-connector.adoc |   3 +-
 .../CamelStringtemplateSinkConnectorConfig.java    |   4 -
 .../src/generated/resources/camel-stub-sink.json   |   7 -
 .../src/generated/resources/camel-stub-source.json |   7 -
 .../main/docs/camel-stub-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-stub-kafka-source-connector.adoc    |   3 +-
 .../stub/CamelStubSinkConnectorConfig.java         |   4 -
 .../stub/CamelStubSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-telegram-sink.json   |   7 -
 .../generated/resources/camel-telegram-source.json |   7 -
 .../docs/camel-telegram-kafka-sink-connector.adoc  |   3 +-
 .../camel-telegram-kafka-source-connector.adoc     |   3 +-
 .../telegram/CamelTelegramSinkConnectorConfig.java |   4 -
 .../CamelTelegramSourceConnectorConfig.java        |   4 -
 .../src/generated/resources/camel-thrift-sink.json |   2 +-
 .../generated/resources/camel-thrift-source.json   |   2 +-
 .../docs/camel-thrift-kafka-sink-connector.adoc    |   2 +-
 .../docs/camel-thrift-kafka-source-connector.adoc  |   2 +-
 .../thrift/CamelThriftSinkConnectorConfig.java     |   2 +-
 .../thrift/CamelThriftSourceConnectorConfig.java   |   2 +-
 .../src/generated/resources/camel-tika-sink.json   |   7 -
 .../main/docs/camel-tika-kafka-sink-connector.adoc |   3 +-
 .../tika/CamelTikaSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-timer-source.json    |   2 +-
 .../docs/camel-timer-kafka-source-connector.adoc   |   2 +-
 .../timer/CamelTimerSourceConnectorConfig.java     |   2 +-
 .../src/generated/resources/camel-twilio-sink.json |   7 -
 .../generated/resources/camel-twilio-source.json   |   7 -
 .../docs/camel-twilio-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-twilio-kafka-source-connector.adoc  |   3 +-
 .../twilio/CamelTwilioSinkConnectorConfig.java     |   4 -
 .../twilio/CamelTwilioSourceConnectorConfig.java   |   4 -
 .../camel-twitter-directmessage-sink.json          |   7 -
 .../camel-twitter-directmessage-source.json        |   7 -
 ...twitter-directmessage-kafka-sink-connector.adoc |   3 +-
 ...itter-directmessage-kafka-source-connector.adoc |   3 +-
 ...melTwitterdirectmessageSinkConnectorConfig.java |   4 -
 ...lTwitterdirectmessageSourceConnectorConfig.java |   4 -
 .../resources/camel-twitter-search-sink.json       |   7 -
 .../resources/camel-twitter-search-source.json     |   7 -
 .../camel-twitter-search-kafka-sink-connector.adoc |   3 +-
 ...amel-twitter-search-kafka-source-connector.adoc |   3 +-
 .../CamelTwittersearchSinkConnectorConfig.java     |   4 -
 .../CamelTwittersearchSourceConnectorConfig.java   |   4 -
 .../resources/camel-twitter-timeline-sink.json     |   7 -
 .../resources/camel-twitter-timeline-source.json   |   7 -
 ...amel-twitter-timeline-kafka-sink-connector.adoc |   3 +-
 ...el-twitter-timeline-kafka-source-connector.adoc |   3 +-
 .../CamelTwittertimelineSinkConnectorConfig.java   |   4 -
 .../CamelTwittertimelineSourceConnectorConfig.java |   4 -
 .../generated/resources/camel-undertow-sink.json   |   7 -
 .../generated/resources/camel-undertow-source.json |   7 -
 .../docs/camel-undertow-kafka-sink-connector.adoc  |   3 +-
 .../camel-undertow-kafka-source-connector.adoc     |   3 +-
 .../undertow/CamelUndertowSinkConnectorConfig.java |   4 -
 .../CamelUndertowSourceConnectorConfig.java        |   4 -
 .../generated/resources/camel-validator-sink.json  |   7 -
 .../docs/camel-validator-kafka-sink-connector.adoc |   3 +-
 .../CamelValidatorSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-velocity-sink.json   |   7 -
 .../docs/camel-velocity-kafka-sink-connector.adoc  |   3 +-
 .../velocity/CamelVelocitySinkConnectorConfig.java |   4 -
 .../generated/resources/camel-vertx-http-sink.json |   7 -
 .../camel-vertx-http-kafka-sink-connector.adoc     |   3 +-
 .../CamelVertxhttpSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-vertx-sink.json  |   7 -
 .../generated/resources/camel-vertx-source.json    |   7 -
 .../docs/camel-vertx-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-vertx-kafka-source-connector.adoc   |   3 +-
 .../vertx/CamelVertxSinkConnectorConfig.java       |   4 -
 .../vertx/CamelVertxSourceConnectorConfig.java     |   4 -
 .../resources/camel-vertx-kafka-sink.json          | 107 +++++-
 .../resources/camel-vertx-kafka-source.json        |  99 ++++-
 .../camel-vertx-kafka-kafka-sink-connector.adoc    |  38 +-
 .../camel-vertx-kafka-kafka-source-connector.adoc  |  30 +-
 .../CamelVertxkafkaSinkConnectorConfig.java        |  72 +++-
 .../CamelVertxkafkaSourceConnectorConfig.java      |  64 +++-
 .../resources/camel-vertx-websocket-sink.json      |   7 -
 .../resources/camel-vertx-websocket-source.json    |   7 -
 ...camel-vertx-websocket-kafka-sink-connector.adoc |   3 +-
 ...mel-vertx-websocket-kafka-source-connector.adoc |   3 +-
 .../CamelVertxwebsocketSinkConnectorConfig.java    |   4 -
 .../CamelVertxwebsocketSourceConnectorConfig.java  |   4 -
 .../src/generated/resources/camel-vm-sink.json     |   7 -
 .../src/generated/resources/camel-vm-source.json   |   7 -
 .../main/docs/camel-vm-kafka-sink-connector.adoc   |   3 +-
 .../main/docs/camel-vm-kafka-source-connector.adoc |   3 +-
 .../vm/CamelVmSinkConnectorConfig.java             |   4 -
 .../vm/CamelVmSourceConnectorConfig.java           |   4 -
 .../generated/resources/camel-weather-sink.json    |   7 -
 .../generated/resources/camel-weather-source.json  |   7 -
 .../docs/camel-weather-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-weather-kafka-source-connector.adoc |   3 +-
 .../weather/CamelWeatherSinkConnectorConfig.java   |   4 -
 .../weather/CamelWeatherSourceConnectorConfig.java |   4 -
 .../src/generated/resources/camel-web3j-sink.json  |   7 -
 .../generated/resources/camel-web3j-source.json    |   7 -
 .../docs/camel-web3j-kafka-sink-connector.adoc     |   3 +-
 .../docs/camel-web3j-kafka-source-connector.adoc   |   3 +-
 .../web3j/CamelWeb3jSinkConnectorConfig.java       |   4 -
 .../web3j/CamelWeb3jSourceConnectorConfig.java     |   4 -
 .../generated/resources/camel-webhook-source.json  |   7 -
 .../docs/camel-webhook-kafka-source-connector.adoc |   3 +-
 .../webhook/CamelWebhookSourceConnectorConfig.java |   4 -
 .../resources/camel-websocket-jsr356-sink.json     |   7 -
 .../resources/camel-websocket-jsr356-source.json   |   7 -
 ...amel-websocket-jsr356-kafka-sink-connector.adoc |   3 +-
 ...el-websocket-jsr356-kafka-source-connector.adoc |   3 +-
 .../CamelWebsocketjsr356SinkConnectorConfig.java   |   4 -
 .../CamelWebsocketjsr356SourceConnectorConfig.java |   4 -
 .../generated/resources/camel-websocket-sink.json  |   7 -
 .../resources/camel-websocket-source.json          |   7 -
 .../docs/camel-websocket-kafka-sink-connector.adoc |   3 +-
 .../camel-websocket-kafka-source-connector.adoc    |   3 +-
 .../CamelWebsocketSinkConnectorConfig.java         |   4 -
 .../CamelWebsocketSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-weka-sink.json   |   7 -
 .../main/docs/camel-weka-kafka-sink-connector.adoc |   3 +-
 .../weka/CamelWekaSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-wordpress-sink.json  |   7 -
 .../resources/camel-wordpress-source.json          |   7 -
 .../docs/camel-wordpress-kafka-sink-connector.adoc |   3 +-
 .../camel-wordpress-kafka-source-connector.adoc    |   3 +-
 .../CamelWordpressSinkConnectorConfig.java         |   4 -
 .../CamelWordpressSourceConnectorConfig.java       |   4 -
 .../generated/resources/camel-workday-sink.json    |   7 -
 .../docs/camel-workday-kafka-sink-connector.adoc   |   3 +-
 .../workday/CamelWorkdaySinkConnectorConfig.java   |   4 -
 .../generated/resources/camel-xchange-sink.json    |   7 -
 .../docs/camel-xchange-kafka-sink-connector.adoc   |   3 +-
 .../xchange/CamelXchangeSinkConnectorConfig.java   |   4 -
 .../src/generated/resources/camel-xj-sink.json     |   7 -
 .../main/docs/camel-xj-kafka-sink-connector.adoc   |   3 +-
 .../xj/CamelXjSinkConnectorConfig.java             |   4 -
 .../resources/camel-xmlsecurity-sign-sink.json     |   7 -
 ...amel-xmlsecurity-sign-kafka-sink-connector.adoc |   3 +-
 .../CamelXmlsecuritysignSinkConnectorConfig.java   |   4 -
 .../resources/camel-xmlsecurity-verify-sink.json   |   7 -
 ...el-xmlsecurity-verify-kafka-sink-connector.adoc |   3 +-
 .../CamelXmlsecurityverifySinkConnectorConfig.java |   4 -
 .../src/generated/resources/camel-xmpp-sink.json   |   7 -
 .../src/generated/resources/camel-xmpp-source.json |   7 -
 .../main/docs/camel-xmpp-kafka-sink-connector.adoc |   3 +-
 .../docs/camel-xmpp-kafka-source-connector.adoc    |   3 +-
 .../xmpp/CamelXmppSinkConnectorConfig.java         |   4 -
 .../xmpp/CamelXmppSourceConnectorConfig.java       |   4 -
 .../src/generated/resources/camel-xquery-sink.json |   7 -
 .../generated/resources/camel-xquery-source.json   |   7 -
 .../docs/camel-xquery-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-xquery-kafka-source-connector.adoc  |   3 +-
 .../xquery/CamelXquerySinkConnectorConfig.java     |   4 -
 .../xquery/CamelXquerySourceConnectorConfig.java   |   4 -
 .../src/generated/resources/camel-xslt-sink.json   |   7 -
 .../main/docs/camel-xslt-kafka-sink-connector.adoc |   3 +-
 .../xslt/CamelXsltSinkConnectorConfig.java         |   4 -
 .../generated/resources/camel-xslt-saxon-sink.json |   7 -
 .../camel-xslt-saxon-kafka-sink-connector.adoc     |   3 +-
 .../CamelXsltsaxonSinkConnectorConfig.java         |   4 -
 .../src/generated/resources/camel-yammer-sink.json |   7 -
 .../generated/resources/camel-yammer-source.json   |   7 -
 .../docs/camel-yammer-kafka-sink-connector.adoc    |   3 +-
 .../docs/camel-yammer-kafka-source-connector.adoc  |   3 +-
 .../yammer/CamelYammerSinkConnectorConfig.java     |   4 -
 .../yammer/CamelYammerSourceConnectorConfig.java   |   4 -
 .../generated/resources/camel-zendesk-sink.json    |   7 -
 .../generated/resources/camel-zendesk-source.json  |   7 -
 .../docs/camel-zendesk-kafka-sink-connector.adoc   |   3 +-
 .../docs/camel-zendesk-kafka-source-connector.adoc |   3 +-
 .../zendesk/CamelZendeskSinkConnectorConfig.java   |   4 -
 .../zendesk/CamelZendeskSourceConnectorConfig.java |   4 -
 .../generated/resources/camel-zookeeper-sink.json  |   7 -
 .../resources/camel-zookeeper-source.json          |   7 -
 .../docs/camel-zookeeper-kafka-sink-connector.adoc |   3 +-
 .../camel-zookeeper-kafka-source-connector.adoc    |   3 +-
 .../CamelZookeeperSinkConnectorConfig.java         |   4 -
 .../CamelZookeeperSourceConnectorConfig.java       |   4 -
 .../resources/camel-zookeeper-master-source.json   |   7 -
 ...el-zookeeper-master-kafka-source-connector.adoc |   3 +-
 .../CamelZookeepermasterSourceConnectorConfig.java |   4 -
 connectors/pom.xml                                 |   7 +
 .../utils/CamelKafkaConnectMain.java               |  16 +-
 .../camel/kafkaconnector/DataFormatTest.java       |   3 +-
 docs/modules/ROOT/nav.adoc                         |  40 ++
 docs/modules/ROOT/pages/connectors.adoc            |   9 +-
 .../camel-activemq-kafka-sink-connector.adoc       |   9 +-
 .../camel-activemq-kafka-source-connector.adoc     |   7 +-
 .../connectors/camel-ahc-kafka-sink-connector.adoc |   3 +-
 .../camel-ahc-ws-kafka-sink-connector.adoc         |   3 +-
 .../camel-ahc-ws-kafka-source-connector.adoc       |   3 +-
 .../camel-ahc-wss-kafka-sink-connector.adoc        |   3 +-
 .../camel-ahc-wss-kafka-source-connector.adoc      |   3 +-
 .../camel-amqp-kafka-sink-connector.adoc           |   9 +-
 .../camel-amqp-kafka-source-connector.adoc         |   7 +-
 .../camel-apns-kafka-sink-connector.adoc           |   3 +-
 .../camel-apns-kafka-source-connector.adoc         |   3 +-
 .../camel-arangodb-kafka-sink-connector.adoc       |   3 +-
 .../connectors/camel-as2-kafka-sink-connector.adoc |   3 +-
 .../camel-as2-kafka-source-connector.adoc          |   3 +-
 .../camel-asterisk-kafka-sink-connector.adoc       |   3 +-
 .../camel-asterisk-kafka-source-connector.adoc     |   3 +-
 .../camel-atlasmap-kafka-sink-connector.adoc       |   3 +-
 .../camel-atmos-kafka-sink-connector.adoc          |   3 +-
 .../camel-atmos-kafka-source-connector.adoc        |   3 +-
 ...-atmosphere-websocket-kafka-sink-connector.adoc |   3 +-
 ...tmosphere-websocket-kafka-source-connector.adoc |   3 +-
 .../camel-atom-kafka-source-connector.adoc         |   3 +-
 .../camel-atomix-map-kafka-sink-connector.adoc     |   3 +-
 .../camel-atomix-map-kafka-source-connector.adoc   |   3 +-
 ...amel-atomix-messaging-kafka-sink-connector.adoc |   3 +-
 ...el-atomix-messaging-kafka-source-connector.adoc |   3 +-
 ...camel-atomix-multimap-kafka-sink-connector.adoc |   3 +-
 .../camel-atomix-queue-kafka-sink-connector.adoc   |   3 +-
 .../camel-atomix-queue-kafka-source-connector.adoc |   3 +-
 .../camel-atomix-set-kafka-sink-connector.adoc     |   3 +-
 .../camel-atomix-set-kafka-source-connector.adoc   |   3 +-
 .../camel-atomix-value-kafka-sink-connector.adoc   |   3 +-
 .../camel-atomix-value-kafka-source-connector.adoc |   3 +-
 .../camel-avro-kafka-sink-connector.adoc           |   3 +-
 .../camel-avro-kafka-source-connector.adoc         |   3 +-
 .../camel-aws-cw-kafka-sink-connector.adoc         |   3 +-
 .../camel-aws-ddb-kafka-sink-connector.adoc        |   3 +-
 ...camel-aws-ddbstream-kafka-source-connector.adoc |   3 +-
 .../camel-aws-ec2-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-ecs-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-eks-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-iam-kafka-sink-connector.adoc        |   3 +-
 ...-aws-kinesis-firehose-kafka-sink-connector.adoc |   3 +-
 .../camel-aws-kinesis-kafka-sink-connector.adoc    |   3 +-
 .../camel-aws-kinesis-kafka-source-connector.adoc  |   3 +-
 .../camel-aws-kms-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-lambda-kafka-sink-connector.adoc     |   3 +-
 .../camel-aws-mq-kafka-sink-connector.adoc         |   3 +-
 .../camel-aws-msk-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-s3-kafka-sink-connector.adoc         |   3 +-
 .../camel-aws-s3-kafka-source-connector.adoc       |   5 +-
 .../camel-aws-sdb-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-ses-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-sns-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-sqs-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-sqs-kafka-source-connector.adoc      |   3 +-
 .../camel-aws-swf-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws-swf-kafka-source-connector.adoc      |   3 +-
 .../camel-aws-translate-kafka-sink-connector.adoc  |   3 +-
 .../camel-aws2-athena-kafka-sink-connector.adoc    |   3 +-
 .../camel-aws2-cw-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws2-ddb-kafka-sink-connector.adoc       |   3 +-
 ...amel-aws2-ddbstream-kafka-source-connector.adoc |   3 +-
 .../camel-aws2-ec2-kafka-sink-connector.adoc       |   3 +-
 .../camel-aws2-ecs-kafka-sink-connector.adoc       |   3 +-
 .../camel-aws2-eks-kafka-sink-connector.adoc       |   3 +-
 ...amel-aws2-eventbridge-kafka-sink-connector.adoc |   3 +-
 .../camel-aws2-iam-kafka-sink-connector.adoc       |   7 +-
 ...aws2-kinesis-firehose-kafka-sink-connector.adoc |   7 +-
 .../camel-aws2-kinesis-kafka-sink-connector.adoc   |   7 +-
 .../camel-aws2-kinesis-kafka-source-connector.adoc |   7 +-
 .../camel-aws2-kms-kafka-sink-connector.adoc       |   3 +-
 .../camel-aws2-lambda-kafka-sink-connector.adoc    |   3 +-
 .../camel-aws2-mq-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws2-msk-kafka-sink-connector.adoc       |   3 +-
 .../camel-aws2-s3-kafka-sink-connector.adoc        |   3 +-
 .../camel-aws2-s3-kafka-source-connector.adoc      |   5 +-
 .../camel-aws2-ses-kafka-sink-connector.adoc       |   3 +-
 .../camel-aws2-sns-kafka-sink-connector.adoc       |   7 +-
 .../camel-aws2-sqs-kafka-sink-connector.adoc       |   9 +-
 .../camel-aws2-sqs-kafka-source-connector.adoc     |   7 +-
 .../camel-aws2-sts-kafka-sink-connector.adoc       |   3 +-
 .../camel-aws2-translate-kafka-sink-connector.adoc |   3 +-
 .../camel-azure-blob-kafka-sink-connector.adoc     |   3 +-
 .../camel-azure-blob-kafka-source-connector.adoc   |   3 +-
 ...camel-azure-eventhubs-kafka-sink-connector.adoc |   3 +-
 ...mel-azure-eventhubs-kafka-source-connector.adoc |   3 +-
 .../camel-azure-queue-kafka-sink-connector.adoc    |   3 +-
 .../camel-azure-queue-kafka-source-connector.adoc  |   3 +-
 ...el-azure-storage-blob-kafka-sink-connector.adoc |   3 +-
 ...-azure-storage-blob-kafka-source-connector.adoc |   3 +-
 ...zure-storage-datalake-kafka-sink-connector.adoc | 116 ++++++
 ...re-storage-datalake-kafka-source-connector.adoc | 116 ++++++
 ...l-azure-storage-queue-kafka-sink-connector.adoc |   3 +-
 ...azure-storage-queue-kafka-source-connector.adoc |   3 +-
 .../camel-bean-kafka-sink-connector.adoc           |   3 +-
 .../camel-beanstalk-kafka-sink-connector.adoc      |   3 +-
 .../camel-beanstalk-kafka-source-connector.adoc    |   3 +-
 .../connectors/camel-box-kafka-sink-connector.adoc |   3 +-
 .../camel-box-kafka-source-connector.adoc          |   3 +-
 .../camel-braintree-kafka-sink-connector.adoc      |   3 +-
 .../camel-caffeine-cache-kafka-sink-connector.adoc |   3 +-
 ...el-caffeine-loadcache-kafka-sink-connector.adoc |   3 +-
 .../camel-chatscript-kafka-sink-connector.adoc     |   3 +-
 .../camel-chunk-kafka-sink-connector.adoc          |   3 +-
 .../camel-cm-sms-kafka-sink-connector.adoc         |   3 +-
 .../camel-cmis-kafka-sink-connector.adoc           |   3 +-
 .../camel-cmis-kafka-source-connector.adoc         |   3 +-
 .../camel-coap+tcp-kafka-sink-connector.adoc       |   3 +-
 .../camel-coap+tcp-kafka-source-connector.adoc     |   3 +-
 .../camel-coap-kafka-sink-connector.adoc           |   3 +-
 .../camel-coap-kafka-source-connector.adoc         |   3 +-
 .../camel-coaps+tcp-kafka-sink-connector.adoc      |   3 +-
 .../camel-coaps+tcp-kafka-source-connector.adoc    |   3 +-
 .../camel-coaps-kafka-sink-connector.adoc          |   3 +-
 .../camel-coaps-kafka-source-connector.adoc        |   3 +-
 .../camel-cometd-kafka-sink-connector.adoc         |   3 +-
 .../camel-cometd-kafka-source-connector.adoc       |   3 +-
 .../camel-cometds-kafka-sink-connector.adoc        |   3 +-
 .../camel-cometds-kafka-source-connector.adoc      |   3 +-
 .../camel-consul-kafka-sink-connector.adoc         |   3 +-
 .../camel-consul-kafka-source-connector.adoc       |   3 +-
 .../camel-controlbus-kafka-sink-connector.adoc     |   3 +-
 .../camel-corda-kafka-sink-connector.adoc          |   3 +-
 .../camel-corda-kafka-source-connector.adoc        |   3 +-
 .../camel-couchbase-kafka-sink-connector.adoc      |   3 +-
 .../camel-couchbase-kafka-source-connector.adoc    |   3 +-
 .../camel-couchdb-kafka-sink-connector.adoc        |   3 +-
 .../camel-couchdb-kafka-source-connector.adoc      |   3 +-
 .../connectors/camel-cql-kafka-sink-connector.adoc |   3 +-
 .../camel-cql-kafka-source-connector.adoc          |   3 +-
 .../camel-cron-kafka-source-connector.adoc         |   3 +-
 .../camel-crypto-cms-kafka-sink-connector.adoc     |   3 +-
 .../camel-crypto-kafka-sink-connector.adoc         |   3 +-
 .../connectors/camel-cxf-kafka-sink-connector.adoc |   2 +-
 .../camel-cxf-kafka-source-connector.adoc          |   3 +-
 .../camel-cxfrs-kafka-sink-connector.adoc          |   2 +-
 .../camel-cxfrs-kafka-source-connector.adoc        |   3 +-
 .../camel-dataformat-kafka-sink-connector.adoc     |   3 +-
 .../camel-direct-kafka-sink-connector.adoc         |   2 +-
 .../camel-direct-kafka-source-connector.adoc       |   2 +-
 .../camel-direct-vm-kafka-sink-connector.adoc      |   3 +-
 .../camel-direct-vm-kafka-source-connector.adoc    |   3 +-
 .../camel-disruptor-kafka-sink-connector.adoc      |   3 +-
 .../camel-disruptor-kafka-source-connector.adoc    |   3 +-
 .../camel-disruptor-vm-kafka-sink-connector.adoc   |   3 +-
 .../camel-disruptor-vm-kafka-source-connector.adoc |   3 +-
 .../connectors/camel-djl-kafka-sink-connector.adoc |   3 +-
 .../connectors/camel-dns-kafka-sink-connector.adoc |   3 +-
 .../camel-docker-kafka-sink-connector.adoc         |   3 +-
 .../camel-docker-kafka-source-connector.adoc       |   3 +-
 .../camel-dozer-kafka-sink-connector.adoc          |   3 +-
 .../camel-drill-kafka-sink-connector.adoc          |   3 +-
 .../camel-dropbox-kafka-sink-connector.adoc        |   3 +-
 .../camel-dropbox-kafka-source-connector.adoc      |   3 +-
 .../camel-ehcache-kafka-sink-connector.adoc        |   3 +-
 .../camel-ehcache-kafka-source-connector.adoc      |   3 +-
 ...el-elasticsearch-rest-kafka-sink-connector.adoc |   3 +-
 .../camel-elsql-kafka-sink-connector.adoc          |   3 +-
 .../camel-elsql-kafka-source-connector.adoc        |   3 +-
 .../camel-etcd-keys-kafka-sink-connector.adoc      |   3 +-
 .../camel-etcd-stats-kafka-sink-connector.adoc     |   3 +-
 .../camel-etcd-stats-kafka-source-connector.adoc   |   3 +-
 .../camel-etcd-watch-kafka-source-connector.adoc   |   3 +-
 .../camel-exec-kafka-sink-connector.adoc           |   3 +-
 .../camel-facebook-kafka-sink-connector.adoc       |   3 +-
 .../camel-facebook-kafka-source-connector.adoc     |   3 +-
 .../camel-fhir-kafka-sink-connector.adoc           |   3 +-
 .../camel-fhir-kafka-source-connector.adoc         |   3 +-
 .../camel-file-kafka-sink-connector.adoc           |   2 +-
 .../camel-file-kafka-source-connector.adoc         |   6 +-
 .../camel-file-watch-kafka-source-connector.adoc   |   3 +-
 .../camel-flatpack-kafka-sink-connector.adoc       |   3 +-
 .../camel-flatpack-kafka-source-connector.adoc     |   3 +-
 .../camel-flink-kafka-sink-connector.adoc          |   3 +-
 .../connectors/camel-fop-kafka-sink-connector.adoc |   3 +-
 .../camel-freemarker-kafka-sink-connector.adoc     |   3 +-
 .../connectors/camel-ftp-kafka-sink-connector.adoc |   2 +-
 .../camel-ftp-kafka-source-connector.adoc          |   6 +-
 .../camel-ftps-kafka-sink-connector.adoc           |   2 +-
 .../camel-ftps-kafka-source-connector.adoc         |   6 +-
 .../camel-ganglia-kafka-sink-connector.adoc        |   3 +-
 .../camel-geocoder-kafka-sink-connector.adoc       |   3 +-
 .../connectors/camel-git-kafka-sink-connector.adoc |   3 +-
 .../camel-git-kafka-source-connector.adoc          |   3 +-
 .../camel-github-kafka-sink-connector.adoc         |   3 +-
 .../camel-github-kafka-source-connector.adoc       |   3 +-
 ...camel-google-bigquery-kafka-sink-connector.adoc |   3 +-
 ...l-google-bigquery-sql-kafka-sink-connector.adoc |   3 +-
 ...camel-google-calendar-kafka-sink-connector.adoc |  15 +-
 ...mel-google-calendar-kafka-source-connector.adoc |  15 +-
 ...gle-calendar-stream-kafka-source-connector.adoc |  11 +-
 .../camel-google-drive-kafka-sink-connector.adoc   |   3 +-
 .../camel-google-drive-kafka-source-connector.adoc |   3 +-
 .../camel-google-mail-kafka-sink-connector.adoc    |   3 +-
 .../camel-google-mail-kafka-source-connector.adoc  |   3 +-
 ...-google-mail-stream-kafka-source-connector.adoc |   3 +-
 .../camel-google-pubsub-kafka-sink-connector.adoc  |   5 +-
 ...camel-google-pubsub-kafka-source-connector.adoc |   3 +-
 .../camel-google-sheets-kafka-sink-connector.adoc  |   3 +-
 ...camel-google-sheets-kafka-source-connector.adoc |   3 +-
 ...oogle-sheets-stream-kafka-source-connector.adoc |   3 +-
 .../camel-gora-kafka-sink-connector.adoc           |   3 +-
 .../camel-gora-kafka-source-connector.adoc         |   3 +-
 .../camel-grape-kafka-sink-connector.adoc          |   3 +-
 .../camel-graphql-kafka-sink-connector.adoc        |   3 +-
 .../camel-grpc-kafka-sink-connector.adoc           |   2 +-
 .../camel-grpc-kafka-source-connector.adoc         |   2 +-
 .../camel-guava-eventbus-kafka-sink-connector.adoc |   3 +-
 ...amel-guava-eventbus-kafka-source-connector.adoc |   3 +-
 ...hazelcast-atomicvalue-kafka-sink-connector.adoc |   3 +-
 ...-hazelcast-instance-kafka-source-connector.adoc |   3 +-
 .../camel-hazelcast-list-kafka-sink-connector.adoc |   3 +-
 ...amel-hazelcast-list-kafka-source-connector.adoc |   3 +-
 .../camel-hazelcast-map-kafka-sink-connector.adoc  |   3 +-
 ...camel-hazelcast-map-kafka-source-connector.adoc |   3 +-
 ...el-hazelcast-multimap-kafka-sink-connector.adoc |   3 +-
 ...-hazelcast-multimap-kafka-source-connector.adoc |   3 +-
 ...camel-hazelcast-queue-kafka-sink-connector.adoc |   3 +-
 ...mel-hazelcast-queue-kafka-source-connector.adoc |   3 +-
 ...zelcast-replicatedmap-kafka-sink-connector.adoc |   3 +-
 ...lcast-replicatedmap-kafka-source-connector.adoc |   3 +-
 ...-hazelcast-ringbuffer-kafka-sink-connector.adoc |   3 +-
 .../camel-hazelcast-seda-kafka-sink-connector.adoc |   3 +-
 ...amel-hazelcast-seda-kafka-source-connector.adoc |   3 +-
 .../camel-hazelcast-set-kafka-sink-connector.adoc  |   3 +-
 ...camel-hazelcast-set-kafka-source-connector.adoc |   3 +-
 ...camel-hazelcast-topic-kafka-sink-connector.adoc |   3 +-
 ...mel-hazelcast-topic-kafka-source-connector.adoc |   3 +-
 .../camel-hbase-kafka-sink-connector.adoc          |   3 +-
 .../camel-hbase-kafka-source-connector.adoc        |   3 +-
 .../camel-hdfs-kafka-sink-connector.adoc           |   3 +-
 .../camel-hdfs-kafka-source-connector.adoc         |   3 +-
 .../camel-http-kafka-sink-connector.adoc           |   3 +-
 .../camel-https-kafka-sink-connector.adoc          |   3 +-
 .../camel-hwcloud-smn-kafka-sink-connector.adoc    |  67 ++++
 ...camel-iec60870-client-kafka-sink-connector.adoc |   3 +-
 ...mel-iec60870-client-kafka-source-connector.adoc |   3 +-
 ...camel-iec60870-server-kafka-sink-connector.adoc |   3 +-
 ...mel-iec60870-server-kafka-source-connector.adoc |   3 +-
 .../camel-ignite-cache-kafka-sink-connector.adoc   |   3 +-
 .../camel-ignite-cache-kafka-source-connector.adoc |   3 +-
 .../camel-ignite-compute-kafka-sink-connector.adoc |   3 +-
 ...camel-ignite-events-kafka-source-connector.adoc |   3 +-
 .../camel-ignite-idgen-kafka-sink-connector.adoc   |   3 +-
 ...amel-ignite-messaging-kafka-sink-connector.adoc |   3 +-
 ...el-ignite-messaging-kafka-source-connector.adoc |   3 +-
 .../camel-ignite-queue-kafka-sink-connector.adoc   |   3 +-
 .../camel-ignite-set-kafka-sink-connector.adoc     |   3 +-
 .../camel-imap-kafka-sink-connector.adoc           |   3 +-
 .../camel-imap-kafka-source-connector.adoc         |   5 +-
 .../camel-imaps-kafka-sink-connector.adoc          |   3 +-
 .../camel-imaps-kafka-source-connector.adoc        |   5 +-
 ...l-infinispan-embedded-kafka-sink-connector.adoc |  80 ++++
 ...infinispan-embedded-kafka-source-connector.adoc |  80 ++++
 .../camel-infinispan-kafka-sink-connector.adoc     |  19 +-
 .../camel-infinispan-kafka-source-connector.adoc   |  25 +-
 .../camel-influxdb-kafka-sink-connector.adoc       |   3 +-
 .../camel-iota-kafka-sink-connector.adoc           |   3 +-
 .../camel-ipfs-kafka-sink-connector.adoc           |   3 +-
 .../connectors/camel-irc-kafka-sink-connector.adoc |   3 +-
 .../camel-irc-kafka-source-connector.adoc          |   3 +-
 .../camel-ironmq-kafka-sink-connector.adoc         |   3 +-
 .../camel-ironmq-kafka-source-connector.adoc       |   3 +-
 .../camel-jbpm-kafka-sink-connector.adoc           |   3 +-
 .../camel-jbpm-kafka-source-connector.adoc         |   2 +-
 .../camel-jclouds-kafka-sink-connector.adoc        |   7 +-
 .../camel-jclouds-kafka-source-connector.adoc      |   7 +-
 .../connectors/camel-jcr-kafka-sink-connector.adoc |   3 +-
 .../camel-jcr-kafka-source-connector.adoc          |   3 +-
 .../camel-jdbc-kafka-sink-connector.adoc           |   3 +-
 .../camel-jetty-kafka-source-connector.adoc        |   3 +-
 .../camel-jgroups-kafka-sink-connector.adoc        |   3 +-
 .../camel-jgroups-kafka-source-connector.adoc      |   3 +-
 .../camel-jgroups-raft-kafka-sink-connector.adoc   |   3 +-
 .../camel-jgroups-raft-kafka-source-connector.adoc |   3 +-
 .../camel-jing-kafka-sink-connector.adoc           |   3 +-
 .../camel-jira-kafka-sink-connector.adoc           |   3 +-
 .../camel-jira-kafka-source-connector.adoc         |   3 +-
 .../connectors/camel-jms-kafka-sink-connector.adoc |   9 +-
 .../camel-jms-kafka-source-connector.adoc          |   7 +-
 .../camel-jmx-kafka-source-connector.adoc          |   3 +-
 .../camel-jolt-kafka-sink-connector.adoc           |   3 +-
 .../camel-jooq-kafka-sink-connector.adoc           |   3 +-
 .../camel-jooq-kafka-source-connector.adoc         |   3 +-
 .../connectors/camel-jpa-kafka-sink-connector.adoc |   3 +-
 .../camel-jpa-kafka-source-connector.adoc          |   3 +-
 .../camel-jslt-kafka-sink-connector.adoc           |   7 +-
 .../camel-json-validator-kafka-sink-connector.adoc |   3 +-
 .../camel-jsonata-kafka-sink-connector.adoc        |   9 +-
 .../camel-jt400-kafka-sink-connector.adoc          |   3 +-
 .../camel-jt400-kafka-source-connector.adoc        |   3 +-
 .../camel-kafka-kafka-sink-connector.adoc          |   6 +-
 .../camel-kafka-kafka-source-connector.adoc        |   6 +-
 .../camel-kamelet-kafka-sink-connector.adoc        |  63 +++
 .../camel-kamelet-kafka-source-connector.adoc      |  60 +++
 ...ubernetes-config-maps-kafka-sink-connector.adoc |   3 +-
 ...etes-custom-resources-kafka-sink-connector.adoc |   3 +-
 ...es-custom-resources-kafka-source-connector.adoc |   3 +-
 ...ubernetes-deployments-kafka-sink-connector.adoc |   3 +-
 ...ernetes-deployments-kafka-source-connector.adoc |   3 +-
 .../camel-kubernetes-hpa-kafka-sink-connector.adoc |   3 +-
 ...amel-kubernetes-hpa-kafka-source-connector.adoc |   3 +-
 .../camel-kubernetes-job-kafka-sink-connector.adoc |   3 +-
 ...amel-kubernetes-job-kafka-source-connector.adoc |   3 +-
 ...kubernetes-namespaces-kafka-sink-connector.adoc |   3 +-
 ...bernetes-namespaces-kafka-source-connector.adoc |   3 +-
 ...amel-kubernetes-nodes-kafka-sink-connector.adoc |   3 +-
 ...el-kubernetes-nodes-kafka-source-connector.adoc |   3 +-
 ...istent-volumes-claims-kafka-sink-connector.adoc |   3 +-
 ...es-persistent-volumes-kafka-sink-connector.adoc |   3 +-
 ...camel-kubernetes-pods-kafka-sink-connector.adoc |   3 +-
 ...mel-kubernetes-pods-kafka-source-connector.adoc |   3 +-
 ...plication-controllers-kafka-sink-connector.adoc |   3 +-
 ...ication-controllers-kafka-source-connector.adoc |   3 +-
 ...netes-resources-quota-kafka-sink-connector.adoc |   3 +-
 ...el-kubernetes-secrets-kafka-sink-connector.adoc |   3 +-
 ...etes-service-accounts-kafka-sink-connector.adoc |   3 +-
 ...l-kubernetes-services-kafka-sink-connector.adoc |   3 +-
 ...kubernetes-services-kafka-source-connector.adoc |   3 +-
 .../camel-kudu-kafka-sink-connector.adoc           |   3 +-
 .../camel-language-kafka-sink-connector.adoc       |   3 +-
 .../camel-ldap-kafka-sink-connector.adoc           |   3 +-
 .../camel-ldif-kafka-sink-connector.adoc           |   3 +-
 .../connectors/camel-log-kafka-sink-connector.adoc |   3 +-
 .../connectors/camel-lpr-kafka-sink-connector.adoc |   3 +-
 .../camel-lucene-kafka-sink-connector.adoc         |   3 +-
 .../camel-lumberjack-kafka-source-connector.adoc   |   3 +-
 .../camel-master-kafka-source-connector.adoc       |   3 +-
 .../camel-metrics-kafka-sink-connector.adoc        |   3 +-
 .../camel-micrometer-kafka-sink-connector.adoc     |   3 +-
 ...-microprofile-metrics-kafka-sink-connector.adoc |   3 +-
 .../camel-milo-client-kafka-sink-connector.adoc    |   8 +-
 .../camel-milo-client-kafka-source-connector.adoc  |   8 +-
 .../camel-milo-server-kafka-sink-connector.adoc    |   3 +-
 .../camel-milo-server-kafka-source-connector.adoc  |   3 +-
 .../camel-mina-kafka-sink-connector.adoc           |   3 +-
 .../camel-mina-kafka-source-connector.adoc         |   3 +-
 .../camel-minio-kafka-sink-connector.adoc          |   3 +-
 .../camel-minio-kafka-source-connector.adoc        |   3 +-
 .../camel-mllp-kafka-sink-connector.adoc           |   3 +-
 .../camel-mllp-kafka-source-connector.adoc         |   3 +-
 .../camel-mongodb-gridfs-kafka-sink-connector.adoc |   3 +-
 ...amel-mongodb-gridfs-kafka-source-connector.adoc |   3 +-
 .../camel-mongodb-kafka-sink-connector.adoc        |   3 +-
 .../camel-mongodb-kafka-source-connector.adoc      |   3 +-
 .../connectors/camel-msv-kafka-sink-connector.adoc |   3 +-
 .../camel-mustache-kafka-sink-connector.adoc       |   3 +-
 .../camel-mvel-kafka-sink-connector.adoc           |   3 +-
 .../camel-mybatis-bean-kafka-sink-connector.adoc   |   3 +-
 .../camel-mybatis-kafka-sink-connector.adoc        |   3 +-
 .../camel-mybatis-kafka-source-connector.adoc      |   3 +-
 .../camel-nagios-kafka-sink-connector.adoc         |   3 +-
 .../camel-nats-kafka-sink-connector.adoc           |   2 +-
 .../camel-nats-kafka-source-connector.adoc         |   3 +-
 .../camel-netty-http-kafka-sink-connector.adoc     |   2 +-
 .../camel-netty-http-kafka-source-connector.adoc   |   2 +-
 .../camel-netty-kafka-sink-connector.adoc          |   2 +-
 .../camel-netty-kafka-source-connector.adoc        |   2 +-
 .../camel-nitrite-kafka-sink-connector.adoc        |   3 +-
 .../camel-nitrite-kafka-source-connector.adoc      |   3 +-
 .../connectors/camel-nsq-kafka-sink-connector.adoc |   3 +-
 .../camel-nsq-kafka-source-connector.adoc          |   3 +-
 .../camel-oaipmh-kafka-sink-connector.adoc         |   3 +-
 .../camel-oaipmh-kafka-source-connector.adoc       |   3 +-
 .../camel-olingo2-kafka-sink-connector.adoc        |   3 +-
 .../camel-olingo2-kafka-source-connector.adoc      |   3 +-
 .../camel-olingo4-kafka-sink-connector.adoc        |   3 +-
 .../camel-olingo4-kafka-source-connector.adoc      |   3 +-
 ...enshift-build-configs-kafka-sink-connector.adoc |   3 +-
 ...amel-openshift-builds-kafka-sink-connector.adoc |   3 +-
 ...amel-openstack-cinder-kafka-sink-connector.adoc |   3 +-
 ...amel-openstack-glance-kafka-sink-connector.adoc |   3 +-
 ...el-openstack-keystone-kafka-sink-connector.adoc |   3 +-
 ...mel-openstack-neutron-kafka-sink-connector.adoc |   3 +-
 .../camel-openstack-nova-kafka-sink-connector.adoc |   3 +-
 ...camel-openstack-swift-kafka-sink-connector.adoc |   3 +-
 .../camel-optaplanner-kafka-sink-connector.adoc    |   3 +-
 .../camel-optaplanner-kafka-source-connector.adoc  |   3 +-
 .../camel-paho-kafka-sink-connector.adoc           |   3 +-
 .../camel-paho-kafka-source-connector.adoc         |   3 +-
 .../camel-paho-mqtt5-kafka-sink-connector.adoc     | 110 ++++++
 .../camel-paho-mqtt5-kafka-source-connector.adoc   | 112 ++++++
 .../connectors/camel-pdf-kafka-sink-connector.adoc |   3 +-
 ...pg-replication-slot-kafka-source-connector.adoc |   3 +-
 .../camel-pgevent-kafka-sink-connector.adoc        |   3 +-
 .../camel-pgevent-kafka-source-connector.adoc      |   3 +-
 ...camel-platform-http-kafka-source-connector.adoc |   3 +-
 .../camel-pop3-kafka-sink-connector.adoc           |   3 +-
 .../camel-pop3-kafka-source-connector.adoc         |   5 +-
 .../camel-pop3s-kafka-sink-connector.adoc          |   3 +-
 .../camel-pop3s-kafka-source-connector.adoc        |   5 +-
 .../camel-pubnub-kafka-sink-connector.adoc         |   3 +-
 .../camel-pubnub-kafka-source-connector.adoc       |   3 +-
 .../camel-pulsar-kafka-sink-connector.adoc         |   3 +-
 .../camel-pulsar-kafka-source-connector.adoc       |   3 +-
 .../camel-quartz-kafka-source-connector.adoc       |   3 +-
 .../camel-quickfix-kafka-sink-connector.adoc       |   3 +-
 .../camel-quickfix-kafka-source-connector.adoc     |   3 +-
 .../camel-rabbitmq-kafka-sink-connector.adoc       |   5 +-
 .../camel-rabbitmq-kafka-source-connector.adoc     |   5 +-
 ...amel-reactive-streams-kafka-sink-connector.adoc |   3 +-
 ...el-reactive-streams-kafka-source-connector.adoc |   3 +-
 .../camel-rest-api-kafka-source-connector.adoc     |   3 +-
 .../camel-rest-kafka-sink-connector.adoc           |   3 +-
 .../camel-rest-kafka-source-connector.adoc         |   3 +-
 .../camel-rest-openapi-kafka-sink-connector.adoc   |   3 +-
 .../camel-rest-swagger-kafka-sink-connector.adoc   |   3 +-
 .../camel-resteasy-kafka-sink-connector.adoc       |   3 +-
 .../camel-resteasy-kafka-source-connector.adoc     |   3 +-
 .../camel-rss-kafka-source-connector.adoc          |   3 +-
 .../camel-saga-kafka-sink-connector.adoc           |   3 +-
 .../camel-salesforce-kafka-sink-connector.adoc     |  15 +-
 .../camel-salesforce-kafka-source-connector.adoc   |  13 +-
 .../camel-sap-netweaver-kafka-sink-connector.adoc  |   3 +-
 .../camel-scheduler-kafka-source-connector.adoc    |   2 +-
 .../camel-schematron-kafka-sink-connector.adoc     |   3 +-
 .../connectors/camel-scp-kafka-sink-connector.adoc |   2 +-
 .../camel-seda-kafka-sink-connector.adoc           |   3 +-
 .../camel-seda-kafka-source-connector.adoc         |   3 +-
 .../camel-service-kafka-source-connector.adoc      |   3 +-
 .../camel-servicenow-kafka-sink-connector.adoc     |   3 +-
 .../camel-servlet-kafka-source-connector.adoc      |   3 +-
 .../camel-sftp-kafka-sink-connector.adoc           |   2 +-
 .../camel-sftp-kafka-source-connector.adoc         |   6 +-
 .../connectors/camel-sip-kafka-sink-connector.adoc |   3 +-
 .../camel-sip-kafka-source-connector.adoc          |   5 +-
 .../camel-sips-kafka-sink-connector.adoc           |   3 +-
 .../camel-sips-kafka-source-connector.adoc         |   5 +-
 .../camel-sjms-kafka-sink-connector.adoc           |  46 +--
 .../camel-sjms-kafka-source-connector.adoc         |  48 +--
 .../camel-sjms2-kafka-sink-connector.adoc          |  46 +--
 .../camel-sjms2-kafka-source-connector.adoc        |  48 +--
 .../camel-slack-kafka-sink-connector.adoc          |   3 +-
 .../camel-slack-kafka-source-connector.adoc        |   3 +-
 .../camel-smpp-kafka-sink-connector.adoc           |   3 +-
 .../camel-smpp-kafka-source-connector.adoc         |   3 +-
 .../camel-smpps-kafka-sink-connector.adoc          |   3 +-
 .../camel-smpps-kafka-source-connector.adoc        |   3 +-
 .../camel-smtp-kafka-sink-connector.adoc           |   3 +-
 .../camel-smtp-kafka-source-connector.adoc         |   5 +-
 .../camel-smtps-kafka-sink-connector.adoc          |   3 +-
 .../camel-smtps-kafka-source-connector.adoc        |   5 +-
 .../camel-snmp-kafka-sink-connector.adoc           |   3 +-
 .../camel-snmp-kafka-source-connector.adoc         |   3 +-
 .../camel-solr-kafka-sink-connector.adoc           |   3 +-
 .../camel-solrCloud-kafka-sink-connector.adoc      |   3 +-
 .../camel-solrs-kafka-sink-connector.adoc          |   3 +-
 .../camel-soroush-kafka-sink-connector.adoc        |   3 +-
 .../camel-soroush-kafka-source-connector.adoc      |   3 +-
 .../camel-spark-kafka-sink-connector.adoc          |   3 +-
 .../camel-splunk-hec-kafka-sink-connector.adoc     |   3 +-
 .../camel-splunk-kafka-sink-connector.adoc         |   3 +-
 .../camel-splunk-kafka-source-connector.adoc       |   3 +-
 .../camel-spring-batch-kafka-sink-connector.adoc   |   3 +-
 .../camel-spring-event-kafka-sink-connector.adoc   |   3 +-
 .../camel-spring-event-kafka-source-connector.adoc |   3 +-
 ...el-spring-integration-kafka-sink-connector.adoc |   3 +-
 ...-spring-integration-kafka-source-connector.adoc |   3 +-
 .../camel-spring-ldap-kafka-sink-connector.adoc    |   3 +-
 ...camel-spring-rabbitmq-kafka-sink-connector.adoc |  72 ++++
 ...mel-spring-rabbitmq-kafka-source-connector.adoc |  94 +++++
 .../camel-spring-redis-kafka-sink-connector.adoc   |   2 +-
 .../camel-spring-redis-kafka-source-connector.adoc |   2 +-
 .../camel-spring-ws-kafka-sink-connector.adoc      |   3 +-
 .../camel-spring-ws-kafka-source-connector.adoc    |   3 +-
 .../connectors/camel-sql-kafka-sink-connector.adoc |   5 +-
 .../camel-sql-kafka-source-connector.adoc          |   5 +-
 .../camel-sql-stored-kafka-sink-connector.adoc     |   3 +-
 .../connectors/camel-ssh-kafka-sink-connector.adoc |   3 +-
 .../camel-ssh-kafka-source-connector.adoc          |   3 +-
 .../camel-stax-kafka-sink-connector.adoc           |   3 +-
 .../camel-stitch-kafka-sink-connector.adoc         |  70 ++++
 .../camel-stomp-kafka-sink-connector.adoc          |   3 +-
 .../camel-stomp-kafka-source-connector.adoc        |   3 +-
 .../camel-stream-kafka-sink-connector.adoc         |   3 +-
 .../camel-stream-kafka-source-connector.adoc       |   3 +-
 ...camel-string-template-kafka-sink-connector.adoc |   3 +-
 .../camel-stub-kafka-sink-connector.adoc           |   3 +-
 .../camel-stub-kafka-source-connector.adoc         |   3 +-
 .../camel-telegram-kafka-sink-connector.adoc       |   3 +-
 .../camel-telegram-kafka-source-connector.adoc     |   3 +-
 .../camel-thrift-kafka-sink-connector.adoc         |   2 +-
 .../camel-thrift-kafka-source-connector.adoc       |   2 +-
 .../camel-tika-kafka-sink-connector.adoc           |   3 +-
 .../camel-timer-kafka-source-connector.adoc        |   2 +-
 .../camel-twilio-kafka-sink-connector.adoc         |   3 +-
 .../camel-twilio-kafka-source-connector.adoc       |   3 +-
 ...twitter-directmessage-kafka-sink-connector.adoc |   3 +-
 ...itter-directmessage-kafka-source-connector.adoc |   3 +-
 .../camel-twitter-search-kafka-sink-connector.adoc |   3 +-
 ...amel-twitter-search-kafka-source-connector.adoc |   3 +-
 ...amel-twitter-timeline-kafka-sink-connector.adoc |   3 +-
 ...el-twitter-timeline-kafka-source-connector.adoc |   3 +-
 .../camel-undertow-kafka-sink-connector.adoc       |   3 +-
 .../camel-undertow-kafka-source-connector.adoc     |   3 +-
 .../camel-validator-kafka-sink-connector.adoc      |   3 +-
 .../camel-velocity-kafka-sink-connector.adoc       |   3 +-
 .../camel-vertx-http-kafka-sink-connector.adoc     |   3 +-
 .../camel-vertx-kafka-kafka-sink-connector.adoc    |  38 +-
 .../camel-vertx-kafka-kafka-source-connector.adoc  |  30 +-
 .../camel-vertx-kafka-sink-connector.adoc          |   3 +-
 .../camel-vertx-kafka-source-connector.adoc        |   3 +-
 ...camel-vertx-websocket-kafka-sink-connector.adoc |   3 +-
 ...mel-vertx-websocket-kafka-source-connector.adoc |   3 +-
 .../connectors/camel-vm-kafka-sink-connector.adoc  |   3 +-
 .../camel-vm-kafka-source-connector.adoc           |   3 +-
 .../camel-weather-kafka-sink-connector.adoc        |   3 +-
 .../camel-weather-kafka-source-connector.adoc      |   3 +-
 .../camel-web3j-kafka-sink-connector.adoc          |   3 +-
 .../camel-web3j-kafka-source-connector.adoc        |   3 +-
 .../camel-webhook-kafka-source-connector.adoc      |   3 +-
 ...amel-websocket-jsr356-kafka-sink-connector.adoc |   3 +-
 ...el-websocket-jsr356-kafka-source-connector.adoc |   3 +-
 .../camel-websocket-kafka-sink-connector.adoc      |   3 +-
 .../camel-websocket-kafka-source-connector.adoc    |   3 +-
 .../camel-weka-kafka-sink-connector.adoc           |   3 +-
 .../camel-wordpress-kafka-sink-connector.adoc      |   3 +-
 .../camel-wordpress-kafka-source-connector.adoc    |   3 +-
 .../camel-workday-kafka-sink-connector.adoc        |   3 +-
 .../camel-xchange-kafka-sink-connector.adoc        |   3 +-
 .../connectors/camel-xj-kafka-sink-connector.adoc  |   3 +-
 ...amel-xmlsecurity-sign-kafka-sink-connector.adoc |   3 +-
 ...el-xmlsecurity-verify-kafka-sink-connector.adoc |   3 +-
 .../camel-xmpp-kafka-sink-connector.adoc           |   3 +-
 .../camel-xmpp-kafka-source-connector.adoc         |   3 +-
 .../camel-xquery-kafka-sink-connector.adoc         |   3 +-
 .../camel-xquery-kafka-source-connector.adoc       |   3 +-
 .../camel-xslt-kafka-sink-connector.adoc           |   3 +-
 .../camel-xslt-saxon-kafka-sink-connector.adoc     |   3 +-
 .../camel-yammer-kafka-sink-connector.adoc         |   3 +-
 .../camel-yammer-kafka-source-connector.adoc       |   3 +-
 .../camel-zendesk-kafka-sink-connector.adoc        |   3 +-
 .../camel-zendesk-kafka-source-connector.adoc      |   3 +-
 .../camel-zookeeper-kafka-sink-connector.adoc      |   3 +-
 .../camel-zookeeper-kafka-source-connector.adoc    |   3 +-
 ...el-zookeeper-master-kafka-source-connector.adoc |   3 +-
 parent/pom.xml                                     |   2 +-
 pom.xml                                            |   2 +-
 tests/itests-azure-storage-blob/pom.xml            |   2 +-
 tests/itests-azure-storage-queue/pom.xml           |   2 +-
 .../source/CamelSourceAzureStorageQueueITCase.java |   2 +
 .../services/kafka/EmbeddedKafkaService.java       |   2 +
 .../kafkaconnect/KafkaConnectEmbedded.java         |   6 +-
 .../common/test/CamelSourceTestSupport.java        |   2 +
 .../mongodb/source/CamelSourceMongoDBITCase.java   |   2 +
 .../sink/CamelRabbitMQPropertyFactory.java         |   2 +-
 .../sjms2/sink/CamelJMSPropertyFactory.java        |   2 +-
 .../sjms2/sink/CamelSinkJMSStartupITCase.java      |   5 +-
 2780 files changed, 20152 insertions(+), 13204 deletions(-)

diff --cc connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-sink-connector.adoc
index 3241751,153358b..11df96a
--- a/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-sink-connector.adoc
+++ b/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-sink-connector.adoc
@@@ -2,7 -2,7 +2,11 @@@
  [[camel-jclouds-kafka-connector-sink]]
  = camel-jclouds-kafka-connector sink configuration
  
++<<<<<<< HEAD
 +Connector Description: Interact with jclouds compute & blobstore service.
++=======
+ Connector Description: Interact with jclouds compute and blobstore service.
++>>>>>>> camel-master
  
  When using camel-jclouds-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
  
diff --cc connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-source-connector.adoc
index 62cfa38,2e940df..7e89348
--- a/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-source-connector.adoc
+++ b/connectors/camel-jclouds-kafka-connector/src/main/docs/camel-jclouds-kafka-source-connector.adoc
@@@ -2,7 -2,7 +2,11 @@@
  [[camel-jclouds-kafka-connector-source]]
  = camel-jclouds-kafka-connector source configuration
  
++<<<<<<< HEAD
 +Connector description: Interact with jclouds compute & blobstore service.
++=======
+ Connector description: Interact with jclouds compute and blobstore service.
++>>>>>>> camel-master
  
  When using camel-jclouds-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:
  
diff --cc connectors/camel-jsonata-kafka-connector/src/main/docs/camel-jsonata-kafka-sink-connector.adoc
index 250d253,f181fff..1e98beb
--- a/connectors/camel-jsonata-kafka-connector/src/main/docs/camel-jsonata-kafka-sink-connector.adoc
+++ b/connectors/camel-jsonata-kafka-connector/src/main/docs/camel-jsonata-kafka-sink-connector.adoc
@@@ -2,7 -2,7 +2,11 @@@
  [[camel-jsonata-kafka-connector-sink]]
  = camel-jsonata-kafka-connector sink configuration
  
++<<<<<<< HEAD
 +Connector Description: JSON to JSON transformation using JSONATA.
++=======
+ Connector Description: Transforms JSON payload using JSONata transformation.
++>>>>>>> camel-master
  
  When using camel-jsonata-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
  
diff --cc docs/modules/ROOT/nav.adoc
index c9a811c,ba70c20..ddb8488
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@@ -170,6 -170,9 +170,12 @@@
  ** camel-azure-storage-blob-kafka-connector
  *** xref:connectors/camel-azure-storage-blob-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-azure-storage-blob-kafka-sink-connector.adoc[Sink Docs]
++<<<<<<< HEAD
++=======
+ ** camel-azure-storage-datalake-kafka-connector
+ *** xref:connectors/camel-azure-storage-datalake-kafka-source-connector.adoc[Source Docs]
+ *** xref:connectors/camel-azure-storage-datalake-kafka-sink-connector.adoc[Sink Docs]
++>>>>>>> camel-master
  ** camel-azure-storage-queue-kafka-connector
  *** xref:connectors/camel-azure-storage-queue-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-azure-storage-queue-kafka-sink-connector.adoc[Sink Docs]
@@@ -406,6 -409,8 +412,11 @@@
  *** xref:connectors/camel-http-kafka-sink-connector.adoc[Sink Docs]
  ** camel-https-kafka-connector
  *** xref:connectors/camel-https-kafka-sink-connector.adoc[Sink Docs]
++<<<<<<< HEAD
++=======
+ ** camel-hwcloud-smn-kafka-connector
+ *** xref:connectors/camel-hwcloud-smn-kafka-sink-connector.adoc[Sink Docs]
++>>>>>>> camel-master
  ** camel-iec60870-client-kafka-connector
  *** xref:connectors/camel-iec60870-client-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-iec60870-client-kafka-sink-connector.adoc[Sink Docs]
@@@ -434,6 -439,9 +445,12 @@@
  ** camel-imaps-kafka-connector
  *** xref:connectors/camel-imaps-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-imaps-kafka-sink-connector.adoc[Sink Docs]
++<<<<<<< HEAD
++=======
+ ** camel-infinispan-embedded-kafka-connector
+ *** xref:connectors/camel-infinispan-embedded-kafka-source-connector.adoc[Source Docs]
+ *** xref:connectors/camel-infinispan-embedded-kafka-sink-connector.adoc[Sink Docs]
++>>>>>>> camel-master
  ** camel-infinispan-kafka-connector
  *** xref:connectors/camel-infinispan-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-infinispan-kafka-sink-connector.adoc[Sink Docs]
@@@ -501,6 -509,9 +518,12 @@@
  ** camel-kafka-kafka-connector
  *** xref:connectors/camel-kafka-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-kafka-kafka-sink-connector.adoc[Sink Docs]
++<<<<<<< HEAD
++=======
+ ** camel-kamelet-kafka-connector
+ *** xref:connectors/camel-kamelet-kafka-source-connector.adoc[Source Docs]
+ *** xref:connectors/camel-kamelet-kafka-sink-connector.adoc[Sink Docs]
++>>>>>>> camel-master
  ** camel-kubernetes-config-maps-kafka-connector
  *** xref:connectors/camel-kubernetes-config-maps-kafka-sink-connector.adoc[Sink Docs]
  ** camel-kubernetes-custom-resources-kafka-connector
@@@ -644,6 -655,9 +667,12 @@@
  ** camel-paho-kafka-connector
  *** xref:connectors/camel-paho-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-paho-kafka-sink-connector.adoc[Sink Docs]
++<<<<<<< HEAD
++=======
+ ** camel-paho-mqtt5-kafka-connector
+ *** xref:connectors/camel-paho-mqtt5-kafka-source-connector.adoc[Source Docs]
+ *** xref:connectors/camel-paho-mqtt5-kafka-sink-connector.adoc[Sink Docs]
++>>>>>>> camel-master
  ** camel-pdf-kafka-connector
  *** xref:connectors/camel-pdf-kafka-sink-connector.adoc[Sink Docs]
  ** camel-pg-replication-slot-kafka-connector
@@@ -773,6 -787,9 +802,12 @@@
  *** xref:connectors/camel-spring-integration-kafka-sink-connector.adoc[Sink Docs]
  ** camel-spring-ldap-kafka-connector
  *** xref:connectors/camel-spring-ldap-kafka-sink-connector.adoc[Sink Docs]
++<<<<<<< HEAD
++=======
+ ** camel-spring-rabbitmq-kafka-connector
+ *** xref:connectors/camel-spring-rabbitmq-kafka-source-connector.adoc[Source Docs]
+ *** xref:connectors/camel-spring-rabbitmq-kafka-sink-connector.adoc[Sink Docs]
++>>>>>>> camel-master
  ** camel-spring-redis-kafka-connector
  *** xref:connectors/camel-spring-redis-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-spring-redis-kafka-sink-connector.adoc[Sink Docs]
@@@ -789,6 -806,8 +824,11 @@@
  *** xref:connectors/camel-ssh-kafka-sink-connector.adoc[Sink Docs]
  ** camel-stax-kafka-connector
  *** xref:connectors/camel-stax-kafka-sink-connector.adoc[Sink Docs]
++<<<<<<< HEAD
++=======
+ ** camel-stitch-kafka-connector
+ *** xref:connectors/camel-stitch-kafka-sink-connector.adoc[Sink Docs]
++>>>>>>> camel-master
  ** camel-stomp-kafka-connector
  *** xref:connectors/camel-stomp-kafka-source-connector.adoc[Source Docs]
  *** xref:connectors/camel-stomp-kafka-sink-connector.adoc[Sink Docs]
diff --cc docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-sink-connector.adoc
index 3241751,153358b..11df96a
--- a/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-sink-connector.adoc
@@@ -2,7 -2,7 +2,11 @@@
  [[camel-jclouds-kafka-connector-sink]]
  = camel-jclouds-kafka-connector sink configuration
  
++<<<<<<< HEAD
 +Connector Description: Interact with jclouds compute & blobstore service.
++=======
+ Connector Description: Interact with jclouds compute and blobstore service.
++>>>>>>> camel-master
  
  When using camel-jclouds-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
  
diff --cc docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-source-connector.adoc
index 62cfa38,2e940df..7e89348
--- a/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-jclouds-kafka-source-connector.adoc
@@@ -2,7 -2,7 +2,11 @@@
  [[camel-jclouds-kafka-connector-source]]
  = camel-jclouds-kafka-connector source configuration
  
++<<<<<<< HEAD
 +Connector description: Interact with jclouds compute & blobstore service.
++=======
+ Connector description: Interact with jclouds compute and blobstore service.
++>>>>>>> camel-master
  
  When using camel-jclouds-kafka-connector as source make sure to use the following Maven dependency to have support for the connector:
  
diff --cc docs/modules/ROOT/pages/connectors/camel-jsonata-kafka-sink-connector.adoc
index 250d253,f181fff..1e98beb
--- a/docs/modules/ROOT/pages/connectors/camel-jsonata-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-jsonata-kafka-sink-connector.adoc
@@@ -2,7 -2,7 +2,11 @@@
  [[camel-jsonata-kafka-connector-sink]]
  = camel-jsonata-kafka-connector sink configuration
  
++<<<<<<< HEAD
 +Connector Description: JSON to JSON transformation using JSONATA.
++=======
+ Connector Description: Transforms JSON payload using JSONata transformation.
++>>>>>>> camel-master
  
  When using camel-jsonata-kafka-connector as sink make sure to use the following Maven dependency to have support for the connector:
  
diff --cc tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java
index 7f8b03c,88f278d..4e33821
--- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java
+++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java
@@@ -70,7 -70,6 +70,8 @@@ public abstract class CamelSourceTestSu
      public void runTest(ConnectorPropertyFactory connectorPropertyFactory, TestMessageConsumer<?> consumer,
                          FunctionalTestMessageProducer producer) throws ExecutionException, InterruptedException {
          connectorPropertyFactory.log();
++
 +        LOG.debug("Initialized the connector and put the data for the test execution");
          getKafkaConnectService().initializeConnector(connectorPropertyFactory);
  
          LOG.debug("Producing test data to be collected by the connector and sent to Kafka");
@@@ -107,7 -106,6 +108,8 @@@
      public void runTestBlocking(ConnectorPropertyFactory connectorPropertyFactory, TestMessageConsumer<?> consumer,
                          FunctionalTestMessageProducer producer) throws ExecutionException, InterruptedException {
          connectorPropertyFactory.log();
++
 +        LOG.debug("Initialized the connector and put the data for the test execution");
          getKafkaConnectService().initializeConnectorBlocking(connectorPropertyFactory, 1);
  
          LOG.debug("Producing test data to be collected by the connector and sent to Kafka");