[camel-kafka-connector] branch automatic-periodic-sync updated (aea4c4a -> 4741705)

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[camel-kafka-connector] branch automatic-periodic-sync updated (aea4c4a -> 4741705)

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

github-bot pushed a change to branch automatic-periodic-sync
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.


    omit aea4c4a  [create-pull-request] automated change
    omit 45cb1ba  [create-pull-request] automated change
    omit 995957e  Upgrade Strimzi to version 0.22.0
    omit 8dc5d68  [create-pull-request] automated change
    omit 6866270  [create-pull-request] automated change
    omit b1da5ff  [create-pull-request] automated change
    omit 34459cb  [create-pull-request] automated change
    omit f54af80  [create-pull-request] automated change
    omit 1b15907  Adjusted the code to CAMEL-16299
    omit a85a209  chore: regen
    omit e806401  Adjusted catalog tests for camel 3.9.0
    omit 3861245  Some folowup improvements fro #969 and #202.
    omit c962725  chore: fix checkstyle.
    omit 99f11df  Fixed itest for netty-http.
    omit 290f065  fix #969 : Convert NettyChannelBufferStreamCache from NettyHttpSource not converted to string.
    omit ef0eb99  Properly handling UnitOfWork by compelting it at the last possible moment, properly fix #202
    omit dff4d98  Fixed flaky hdfs itest.
    omit f315719  fixed #980 : camel.source.contentLogLevel config not honored in source connectors
    omit cc49c17  [create-pull-request] automated change
    omit dc2f739  Camel Compatibility Matrix: Updated with 0.8.x and 0.7.x maintenance releases
    omit a6b1bac  [create-pull-request] automated change
    omit 627b383  Added Google pub/sub sink integration test
    omit f346be2  [create-pull-request] automated change
    omit 304215e  Remove duplicate slashes (//) on Netty tests
    omit f8df2de  Replace the sleep w/ the reusable test utilities for waiting for the port to be open
    omit 3d96ebc  Remove duplicate slashes (//) to comply with recent netty URI changes on Camel (ref: CAMEL-16280)
    omit 758bf1e  Fix Netty tests reliability
    omit 0ee8710  Remove duplicate run test method
    omit 5bc30a0  Add netty sink itest #1036
    omit b253e13  Add Netty source itest #1036
    omit fabc832  Re-enables the basic test for couchbase since it was fixed on CAMEL-16284
    omit 28db5ba  Add integration tests for AWS v2 lambda
    omit d749b06  Ensure all tests have timeouts
    omit a62f046  Removed deprecated connector based on camel-aws-swf
    omit 7c8d46e  Regen catalog and docs with the removed connectors
    omit 1fd602a  Remove Azure connectors that were deprecated/removed from Camel 3.9 (CAMEL-16246)
    omit 4d83b7f  Remove AWS connectors that were deprecated/removed from Camel 3.9
    omit 7e7bdcf  Remove unnecessary toString for getAbsolutePath() which already returns a String
    omit 86dd160  Avoid hard-coded separators and they can cause portability problems
    omit 4c55fb3  Provide better details if unable to delete the Maven artifact file
    omit cb00dc5  Avoid type specification on constructors when possible
    omit bb5224f  Avoid a very unlikely NPE if the overridePomFile flag is null
    omit f0326c9  Ensure file input streams are closed after use
    omit 8d6d2a0  Rename the avroData bytes to avoid confusion with the member variable also named avroData
    omit c428800  Remove unnecessary close calls which are handled by try-with-resources
    omit 4409b13  Use isEmpty for emptiness check as it's a bit more idiomatic
    omit 7cd6d97  The count of transforms, converter and aggregation strategy seems to be broken for docs - Regen
    omit ac0314f  The count of transforms, converter and aggregation strategy seems to be broken for docs
    omit 019be4f  Regen connectors for Camel 3.9
    omit 29cc405  Upgrade camel version to 3.9.0-SNAPSHOT
    omit 08d85bc  Removed AWS v1 code which was deprecated on Camel 3.9
    omit 8659120  Bumps the version to 0.9.0-SNAPSHOT
    omit 8246cb6  Add SMT for GenericFile of Camel-file-kafka-connector - Regen docs
    omit 8e18da3  Fixed CS
    omit ae33d52  Add SMT for GenericFile of Camel-file-kafka-connector
    omit 865903e  Regen all configs with secret/sensitive values (ref: issue #1050)
    omit b6b211a  Prevent sensitive data marked as secret config in Camel from leaking in Kafka Connect logs (issue #1050)
    omit da58b33  Convert the CXF source test case to use the base source test class
    omit cf14fc4  Convert the CXF sink test case to use the base Sink test class
    omit 6bf32d8  Regen docs table
    omit e131c0b  Website: connectors' list formatting problems
    omit 38ca576  Remove wrong backported file
    omit 237a429  Regen packages and documentation
    omit 1840624  Generate just one connector package: .zip or .tar.gz
    omit 6d36abb  Generate just one connector package: .zip or .tar.gz
    omit 8abfa8a  Generate just one connector package: .zip or .tar.gz
    omit 65415a9  Abstracted the CXF service client setup from the CXF test code
    omit 4870fd5  Refactor the CXF servers into a service for simpler reuse
    omit 16b10aa  Add gh action for daily maven plugins IT
    omit c63b291  Regen docs for 0.7.2
    omit 804ec28  Last released version is 0.7.2
    omit 7b6a380  Added remove headers doc page to nav
    omit 009134d  Added remove headers page to index.adoc
    omit f1d057e  Added remove headers documentation
    omit eb81f69  Avoid using static hostnames in tests
    omit a2331bd  Fixed checkstyle issues with the CXF integration tests
    omit 3a0b74c  Temporarily disable the syslog source tests on Github
    omit a864c7e  Make sure CXF tests are included in the test run
     add b213e2e  Removed newline from README
     add 8f9976c  Remove rebase camel-master on master, it is too buggy
     add 5d7ace7  Removed node setup from backport action
     add e3a0cf6  Backport action: Added license
     add 0fb9ee4  Changelog action added as submodule
     add b91f75d  Revert "Remove Github changelog action"
     add 08d53dd  Changelog action modified to work with submodule
     add 8c8767d  Updated CHANGELOG.md
     add 530785a  Added a basic test for idempotency
     add 3f1a3be  Updated CHANGELOG.md
     add cc371d7  Avoid reusing the same destination name for the sjms2 idempotency tests
     add 3ffb61a  Added idempotency test for SJMS2 using header expressions
     add d48f680  Add connector entries to doc nav
     add 0199c09  Test PR
     add 88850c9  Test PR
     add 18e9c49  TEST
     add e03dae4  Update README.adoc
     add c61a462  Test PR
     add 5bbb8fe  SJMS2 itests: Avoid creating a new consumer for every message received
     add 2d4544f  Revert "Test PR"
     add 3964750  Make the AWS v2 sink test support reusable
     add cc35b51  Convert the AWS v1 tests to the new reusable sink test base class
     add c86e53d  Convert the Azure storage blob tests to the new reusable sink test base class
     add 492f19a  Convert the Azure storage queue tests to the new reusable sink test base class
     add 79a5f91  Convert the Cassandra tests to the new reusable sink test base class
     add 8ea604c  Convert the Couchbase tests to the new reusable sink test base class
     add 0ac1afa  Convert the ElasticSearch tests to the new reusable sink test base class
     add 7ab1475  Convert the File tests to the new reusable sink test base class
     add 40ac033  Convert the HDFS tests to the new reusable sink test base class
     add be88da6  Convert the HTTP tests to the new reusable sink test base class
     add 7936a93  Convert the JDBC tests to the new reusable sink test base class
     add 5ca2ddf  Convert the MongoDB tests to the new reusable sink test base class
     add 892cc45  Convert the RabbitMQ tests to the new reusable sink test base class
     add 3f05e11  Removed unused variables from SJMS2 DQL sink test
     add 58d450c  Convert the SJMS2 tests to the new reusable sink test base class
     add 18c5417  Convert the SQL tests to the new reusable sink test base class
     add 36f3f9b  Convert the SSH tests to the new reusable sink test base class
     add b6a1bb9  Convert the Syslog tests to the new reusable sink test base class
     add 4e765be  Updated CHANGELOG.md
     add 87d63c2  Make producing test messages for sink tests more flexible
     add b72ebe8  Updated CHANGELOG.md
     add 7a72ce6  Fix Camel compatibility matrix table
     add ba2617f  Updated CHANGELOG.md
     add 3da3b50  Updated CHANGELOG.md
     add 88d6980  Override Camel's testcontainer version and upgrade to 1.15.1 due to GH issue #990
     add 084c8f0  Added missing slow tests filter to avoid trying to run the AWS v2 test on GH actions
     add cdbeea8  Added a reusable base class for the source tests
     add 293ed7d  Converted AWS source tests to use the reusable source base class
     add fdeee2a  Converted the Azure storage queue source test case to use the reusable source base class
     add ac80745  Converted the Cassandra source test case to use the reusable source base class
     add d6f900d  Converted the MongoDB source test case to use the reusable source base class
     add fd96d0f  Converted the RabbitMQ source test case to use the reusable source base class
     add 6145ff4  Converted the SJMS2 source test cases to use the reusable source base class
     add d1f8099  Converted the SQL source test case to use the reusable source base class
     add dafface  Converted the SSH source test case to use the reusable source base class
     add 85b9701  Converted the Syslog source test case to use the reusable source base class
     add 99cebce  Converted the Timer source test case to use the reusable source base class
     add 483752e  Improve description of connector in documentation
     add 224ae8f  #873 initial cxf Source/Sink connectors test (#940)
     add 905565a  Regen connectors with descriptions
     add 5469e2c  Avoid creating everything from scratch for every Cassandra sink test
     add 15f96dd  Updated CHANGELOG.md
     add aebea74  Fix table format in camel-kafka-connector-generator-maven-plugin adoc
     add 8712c16  Fix missing default values in camel-kafka-connector-generator-maven-plugin options table
     add c5ac647  Updated CHANGELOG.md
     add 0558496  Updated CHANGELOG.md
     add 711d6c1  Avoid blocking connector initialization on SSH tests as it leads to failures on GH actions
     add adfda48  Bump Testcontainers to version 1.15.2
     add a7bcc56  Give another run on test failures to rule out false negatives due to slow CI environments
     add 2df8dc9  Rework the syslog integration tests to let JUnit handle camel's lifecycle in the test
     add 1a85da6  Cleanup the check state logic on the KafkaConnectEmbeddedService
     add 2d9eb17  Updated CHANGELOG.md
     add c79f2a7  Fix problem when call 'context.errantRecordReporter()' will result in a NoSuchMethodException or NoClassDefFoundError when the sink connector is deployed to Connect runtimes older than Kafka 2.6
     add e783715  Updated CHANGELOG.md
     add 3cf956d  Added AWS v2 SNS sink integration test
     add f9accd8  Ensure parallel builds with mvnd work on clean environments
     add 671e1ea  Updated CHANGELOG.md
     add 6f800e3  Avoid spawning Jetty servers too quickly as they seem to cause GH actions to fail
     add cc76192  Delay starting the producer on the syslog test to avoid failing due to port not being available
     add 145a8af  Merge camel-master to master
     add 55e21bc  Regen
     add 862d4b1  Point to Camel-3.8.0
     add 0be62ae  Regen after upgrading to 3.8.0
     add 7cec1a3  Updated CHANGELOG.md
     add c1ecf7e  Add tests to camel-kafka-connector-generator-maven-plugin
     add 4ee63b3  Make sure CXF tests are included in the test run
     add 1ef6980  Temporarily disable the syslog source tests on Github
     add 5d06dab  Fixed checkstyle issues with the CXF integration tests
     add 09f79c6  Updated CHANGELOG.md
     add e6792ce  Added remove headers documentation
     add 5a35fce  Added remove headers page to index.adoc
     add bdcd070  Added remove headers doc page to nav
     add 3b91864  fixed #980 : camel.source.contentLogLevel config not honored in source connectors
     add 3a42e13  Updated CHANGELOG.md
     add 92e9da7  Last released version is 0.7.2
     add d995bcb  Regen documentation with 0.7.2
     add b333637  Add gh action for daily maven plugins IT
     add cb72908  Generate just one connector package: .zip or .tar.gz
     add 2a8255b  Generate just one connector package: .zip or .tar.gz
     add 9b3aca8  Generate just one connector package: .zip or .tar.gz
     add b1c7337  Regen assemblies and docs
     add 1279b62  Website: connectors' list formatting problems
     add 5823944  Regen docs table
     add f2ba5a6  Updated CHANGELOG.md
     add e4605e3  Updated CHANGELOG.md
     add eb4197f  Updated CHANGELOG.md
     add fffbb4c  Prepare archetypes version for release.
     add 6ab89d4  [maven-release-plugin] prepare release camel-kafka-connector-0.8.0
     add 45e01e2  [maven-release-plugin] prepare for next development iteration
     add e5d1da1  Updated CHANGELOG.md
     add 6b7dd7f  Added 0.7.1 and 0.7.2 release to camel compatibility matrix
     add 92efcd3  Updated CHANGELOG.md
     add 6b55539  Fix Maven plugin IT GH action
     add 03eb3eb  Add SMT for GenericFile of Camel-file-kafka-connector
     add f63888d  Add SMT for GenericFile of Camel-file-kafka-connector - Regen docs
     add 7c1dc32  Fixed CS
     add 91fe59d  The count of transforms, converter and aggregation strategy seems to be broken for docs
     add 516f615  The count of transforms, converter and aggregation strategy seems to be broken for docs - Regen
     add b0f50b0  Updated CHANGELOG.md
     add 3d9caea  Add Netty source itest #1036
     add 5126572  Updated CHANGELOG.md
     add 853b97f  chore: update latestReleasedVersion to 0.8.0 and regen.
     add 7a9df72  Updated CHANGELOG.md
     add 7f58c0c  Updated CHANGELOG.md
     add 010ac71  Updated CHANGELOG.md
     add ea4104a  Updated CHANGELOG.md
     add a68e595  Add netty sink itest #1036
     add e6a1b71  Prevent sensitive data marked as secret config in Camel from leaking in Kafka Connect logs (issue #1050)
     add 22d86e3  Regen all configs with secret/sensitive values (ref: issue #1050)
     add e1dd911  Avoid using static hostnames in tests
     add a96e2cf  Refactor the CXF servers into a service for simpler reuse
     add 5225149  Abstracted the CXF service client setup from the CXF test code
     add 633931b  Convert the CXF sink test case to use the base Sink test class
     add d062ce4  Convert the CXF source test case to use the base source test class
     add 281c974  Updated CHANGELOG.md
     add 2a045fd  Use isEmpty for emptiness check as it's a bit more idiomatic
     add b73b024  Remove unnecessary close calls which are handled by try-with-resources
     add b760dae  Rename the avroData bytes to avoid confusion with the member variable also named avroData
     add f94d7b7  Ensure file input streams are closed after use
     add 379b240  Avoid a very unlikely NPE if the overridePomFile flag is null
     add 2984a52  Avoid type specification on constructors when possible
     add 23665f3  Provide better details if unable to delete the Maven artifact file
     add 6db1487  Avoid hard-coded separators and they can cause portability problems
     add 4d452f3  Remove unnecessary toString for getAbsolutePath() which already returns a String
     add f124fa5  Add integration tests for AWS v2 lambda
     add 10ef1d6  Ensure all tests have timeouts
     add 45e0127  Fix Netty tests reliability
     add 990991f  Added Camel-Kafka-connector 0.8.0 to compatibility matrix
     add 68d21a0  Updated CHANGELOG.md
     add c2d6a93  Add netty-http itests #1036
     add a3a8098  Updated CHANGELOG.md
     add 35a0838  Added Google pub/sub sink integration test
     add 7671354  Updated CHANGELOG.md
     add 744e903  Updated CHANGELOG.md
     add 42456d6  Fixed flaky hdfs itest.
     add 2a1a507  Properly handling UnitOfWork by compelting it at the last possible moment, properly fix #202
     add 63ef1f0  fix #969 : Convert NettyChannelBufferStreamCache from NettyHttpSource not converted to string.
     add f6a3e04  Fixed itest for netty-http.
     add 98f6ffb  chore: fix checkstyle.
     add fc9a01c  Updated CHANGELOG.md
     add de36a0a  Some folowup improvements fro #969 and #202.
     add df14db0  Updated CHANGELOG.md
     add d6ad53a  Updated CHANGELOG.md
     add e6ef704  Updated CHANGELOG.md
     add 4d52cb1  Add https itests
     add d9893e5  Reproduced issue #1077 - HTTPS-sink-connector duplicates protocol
     add 5d53f95  Updated CHANGELOG.md
     add ad2d9e6  Introduce MockWebServer extension for testing #1085
     add 8646c64  Extract HTTP-related test common into itests-common-http
     add 6d17b34  Updated CHANGELOG.md
     add 5d52272  Updated CHANGELOG.md
     add 213b29a  Fix https itests to even pass the disabled test (once it's enabled)
     add 9d2d996  Updated CHANGELOG.md
     add 45f27b3  Upgrade Strimzi to version 0.22.0
     add b33d783  Updated CHANGELOG.md
     add 0350057  NetworkUtils should be able to hold a free port for later usage #1109 (#1111)
     add c046727  add itests for camel-cxfrs-kafka-connector #996 (#1099)
     add 96ce948  Updated CHANGELOG.md
     add 2385a11  Updated CHANGELOG.md
     add 9ca0ad0  Updated CHANGELOG.md
     add 86d06c8  Updated CHANGELOG.md
     add 337c65c  Updated CHANGELOG.md
     add 40195d9  Upgrade Strimzi to version 0.22.1
     add e0051fb  Fixed CS in cxfrs itest
     add 92cd3d9  Add Camel 3.7.3 and ckc 0.7.3 to compatibility matrix
     add e274e64  Updated CHANGELOG.md
     add 09f213a  Updated CHANGELOG.md
     add cb941b5  Updated CHANGELOG.md
     add 3ffc867  Updated CHANGELOG.md
     add d128b9a  Updated CHANGELOG.md
     add c824ad7  Adjusted catalog tests for camel 3.9.0
     add 267ab14  Adjusted the code to CAMEL-16299
     add 970d92d  Upgrade Camel to 3.9.0
     add df8294c  Align to 3.9.0
     add cd32688  Align to 3.9.0
     add de9bacc  Align to 3.9.0
     add d660dd6  Align to 3.9.0
     add 4d9cfd3  Regen
     add d5a4d5f  Align to 3.9.0
     add 0d195f7  Updated CHANGELOG.md
     add 6cc3d9c  Updated tests after camel 3.9.0 fixed #924.
     add 923b4be  chore: test flakyness mitigation.
     add 83633f4  [maven-release-plugin] prepare release camel-kafka-connector-0.9.0
     add ab8d260  [maven-release-plugin] prepare for next development iteration
     add b385b40  Updated CHANGELOG.md
     add a9d2b25  Updated CHANGELOG.md
     add c1cc559  Fix HTTPS-sink-connector duplicates protocol #1077
     add d5602d4  Updated CHANGELOG.md
     add d03399d  Re-enabled MongoDB source test after moving to Camel 3.9.0 (issue #974)
     add 3612081  Re-enabled Google pub/sub test
     add 9bf5e02  Updated CHANGELOG.md
     add 83482d3  Updated CHANGELOG.md
     add 03e5f14  Updated CHANGELOG.md
     add bf93b53  Updated CHANGELOG.md
     add 242bba9  Updated CHANGELOG.md
     add be8d776   SMT FieldsToHeaders Documentation  #902
     add b16de9d  Point to 3.10.0-SNAPSHOT
     add 042711e  Align to 3.10.0-SNAPSHOT
     add 3534b1d  Build the sync PR on master and not on camel-master
     add cd2c66a  CI-Build: No need for building camel-master anymore
     add 436b2c4  CI-build sync master: Changed title
     add 4a10555  CI-build sync master: Changed title
     add 78a0b32  Updated CHANGELOG.md
     add 4741705  [create-pull-request] automated change

This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version.  This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:

 * -- * -- B -- O -- O -- O   (aea4c4a)
            \
             N -- N -- N   refs/heads/automatic-periodic-sync (4741705)

You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

No new revisions were added by this update.

Summary of changes:
 .github/workflows/automatic-sync-camel-master.yml  |  10 +-
 .github/workflows/ci-build.yml                     |   2 -
 .github/workflows/maven-it.yaml                    |   1 +
 CHANGELOG.md                                       | 312 +++++++++-
 .../pom.xml                                        |   2 +-
 .../pom.xml                                        |   2 +-
 .../archetype.properties                           |   2 +-
 .../pom.xml                                        |   2 +-
 archetypes/pom.xml                                 |   2 +-
 buildingtools/pom.xml                              |   2 +-
 .../resources/camel-checkstyle-suppressions.xml    |   6 +
 camel-kafka-connector-catalog/pom.xml              |   2 +-
 .../resources/connectors/camel-activemq-sink.json  |   2 +-
 .../connectors/camel-activemq-source.json          |   2 +-
 .../resources/connectors/camel-ahc-sink.json       |   2 +-
 .../resources/connectors/camel-ahc-ws-sink.json    |   2 +-
 .../resources/connectors/camel-ahc-ws-source.json  |   2 +-
 .../resources/connectors/camel-ahc-wss-sink.json   |   2 +-
 .../resources/connectors/camel-ahc-wss-source.json |   2 +-
 .../resources/connectors/camel-amqp-sink.json      |   2 +-
 .../resources/connectors/camel-amqp-source.json    |   2 +-
 .../resources/connectors/camel-apns-sink.json      |   2 +-
 .../resources/connectors/camel-apns-source.json    |   2 +-
 .../resources/connectors/camel-arangodb-sink.json  |   2 +-
 .../resources/connectors/camel-as2-sink.json       |   2 +-
 .../resources/connectors/camel-as2-source.json     |   2 +-
 .../resources/connectors/camel-asterisk-sink.json  |   2 +-
 .../connectors/camel-asterisk-source.json          |   2 +-
 .../resources/connectors/camel-atlasmap-sink.json  |   2 +-
 .../resources/connectors/camel-atmos-sink.json     |   2 +-
 .../resources/connectors/camel-atmos-source.json   |   2 +-
 .../camel-atmosphere-websocket-sink.json           |   2 +-
 .../camel-atmosphere-websocket-source.json         |   2 +-
 .../resources/connectors/camel-atom-source.json    |   2 +-
 .../connectors/camel-atomix-map-sink.json          |   2 +-
 .../connectors/camel-atomix-map-source.json        |   2 +-
 .../connectors/camel-atomix-messaging-sink.json    |   2 +-
 .../connectors/camel-atomix-messaging-source.json  |   2 +-
 .../connectors/camel-atomix-multimap-sink.json     |   2 +-
 .../connectors/camel-atomix-queue-sink.json        |   2 +-
 .../connectors/camel-atomix-queue-source.json      |   2 +-
 .../connectors/camel-atomix-set-sink.json          |   2 +-
 .../connectors/camel-atomix-set-source.json        |   2 +-
 .../connectors/camel-atomix-value-sink.json        |   2 +-
 .../connectors/camel-atomix-value-source.json      |   2 +-
 .../resources/connectors/camel-avro-sink.json      |   2 +-
 .../resources/connectors/camel-avro-source.json    |   2 +-
 .../resources/connectors/camel-aws-cw-sink.json    |   2 +-
 .../resources/connectors/camel-aws-ddb-sink.json   |   2 +-
 .../connectors/camel-aws-ddbstream-source.json     |   2 +-
 .../resources/connectors/camel-aws-ec2-sink.json   |   2 +-
 .../resources/connectors/camel-aws-ecs-sink.json   |   2 +-
 .../resources/connectors/camel-aws-eks-sink.json   |   2 +-
 .../resources/connectors/camel-aws-iam-sink.json   |   2 +-
 .../camel-aws-kinesis-firehose-sink.json           |   2 +-
 .../connectors/camel-aws-kinesis-sink.json         |   2 +-
 .../connectors/camel-aws-kinesis-source.json       |   2 +-
 .../resources/connectors/camel-aws-kms-sink.json   |   2 +-
 .../connectors/camel-aws-lambda-sink.json          |   2 +-
 .../resources/connectors/camel-aws-mq-sink.json    |   2 +-
 .../resources/connectors/camel-aws-msk-sink.json   |   2 +-
 .../resources/connectors/camel-aws-s3-sink.json    |   2 +-
 .../resources/connectors/camel-aws-s3-source.json  |   2 +-
 .../resources/connectors/camel-aws-sdb-sink.json   |   2 +-
 .../connectors/camel-aws-secrets-manager-sink.json |  12 +-
 .../resources/connectors/camel-aws-ses-sink.json   |   2 +-
 .../resources/connectors/camel-aws-sns-sink.json   |   2 +-
 .../resources/connectors/camel-aws-sqs-sink.json   |   2 +-
 .../resources/connectors/camel-aws-sqs-source.json |   2 +-
 .../connectors/camel-aws-translate-sink.json       |   2 +-
 .../connectors/camel-aws2-athena-sink.json         |   2 +-
 .../resources/connectors/camel-aws2-cw-sink.json   |   2 +-
 .../resources/connectors/camel-aws2-ddb-sink.json  |   2 +-
 .../connectors/camel-aws2-ddbstream-source.json    |   2 +-
 .../resources/connectors/camel-aws2-ec2-sink.json  |   2 +-
 .../resources/connectors/camel-aws2-ecs-sink.json  |   2 +-
 .../resources/connectors/camel-aws2-eks-sink.json  |   2 +-
 .../connectors/camel-aws2-eventbridge-sink.json    |   2 +-
 .../resources/connectors/camel-aws2-iam-sink.json  |   2 +-
 .../camel-aws2-kinesis-firehose-sink.json          |  16 +-
 .../connectors/camel-aws2-kinesis-sink.json        |  16 +-
 .../connectors/camel-aws2-kinesis-source.json      |  16 +-
 .../resources/connectors/camel-aws2-kms-sink.json  |   2 +-
 .../connectors/camel-aws2-lambda-sink.json         |   2 +-
 .../resources/connectors/camel-aws2-mq-sink.json   |   2 +-
 .../resources/connectors/camel-aws2-msk-sink.json  |   2 +-
 .../resources/connectors/camel-aws2-s3-sink.json   |  78 ++-
 .../resources/connectors/camel-aws2-s3-source.json |   2 +-
 .../resources/connectors/camel-aws2-ses-sink.json  |   2 +-
 .../resources/connectors/camel-aws2-sns-sink.json  |   2 +-
 .../resources/connectors/camel-aws2-sqs-sink.json  |   2 +-
 .../connectors/camel-aws2-sqs-source.json          |   2 +-
 .../resources/connectors/camel-aws2-sts-sink.json  |   2 +-
 .../connectors/camel-aws2-translate-sink.json      |   2 +-
 .../connectors/camel-azure-eventhubs-sink.json     |   2 +-
 .../connectors/camel-azure-eventhubs-source.json   |   2 +-
 .../connectors/camel-azure-storage-blob-sink.json  |   2 +-
 .../camel-azure-storage-blob-source.json           |   2 +-
 .../camel-azure-storage-datalake-sink.json         |   2 +-
 .../camel-azure-storage-datalake-source.json       |   2 +-
 .../connectors/camel-azure-storage-queue-sink.json |   2 +-
 .../camel-azure-storage-queue-source.json          |   2 +-
 .../resources/connectors/camel-bean-sink.json      |   2 +-
 .../resources/connectors/camel-beanstalk-sink.json |   2 +-
 .../connectors/camel-beanstalk-source.json         |   2 +-
 .../resources/connectors/camel-box-sink.json       |   2 +-
 .../resources/connectors/camel-box-source.json     |   2 +-
 .../resources/connectors/camel-braintree-sink.json |   2 +-
 .../connectors/camel-caffeine-cache-sink.json      |   2 +-
 .../connectors/camel-caffeine-loadcache-sink.json  |   2 +-
 .../connectors/camel-chatscript-sink.json          |   2 +-
 .../resources/connectors/camel-chunk-sink.json     |   2 +-
 .../resources/connectors/camel-cm-sms-sink.json    |   2 +-
 .../resources/connectors/camel-cmis-sink.json      |   2 +-
 .../resources/connectors/camel-cmis-source.json    |   2 +-
 .../resources/connectors/camel-coap+tcp-sink.json  |   2 +-
 .../connectors/camel-coap+tcp-source.json          |   2 +-
 .../resources/connectors/camel-coap-sink.json      |   2 +-
 .../resources/connectors/camel-coap-source.json    |   2 +-
 .../resources/connectors/camel-coaps+tcp-sink.json |   2 +-
 .../connectors/camel-coaps+tcp-source.json         |   2 +-
 .../resources/connectors/camel-coaps-sink.json     |   2 +-
 .../resources/connectors/camel-coaps-source.json   |   2 +-
 .../resources/connectors/camel-cometd-sink.json    |   2 +-
 .../resources/connectors/camel-cometd-source.json  |   2 +-
 .../resources/connectors/camel-cometds-sink.json   |   2 +-
 .../resources/connectors/camel-cometds-source.json |   2 +-
 .../resources/connectors/camel-consul-sink.json    |   2 +-
 .../resources/connectors/camel-consul-source.json  |   2 +-
 .../connectors/camel-controlbus-sink.json          |   2 +-
 .../resources/connectors/camel-corda-sink.json     |   2 +-
 .../resources/connectors/camel-corda-source.json   |   2 +-
 .../resources/connectors/camel-couchbase-sink.json |   2 +-
 .../connectors/camel-couchbase-source.json         |   2 +-
 .../resources/connectors/camel-couchdb-sink.json   |   2 +-
 .../resources/connectors/camel-couchdb-source.json |   2 +-
 .../resources/connectors/camel-cql-sink.json       |   2 +-
 .../resources/connectors/camel-cql-source.json     |   2 +-
 .../resources/connectors/camel-cron-source.json    |   2 +-
 .../connectors/camel-crypto-cms-sink.json          |   2 +-
 .../resources/connectors/camel-crypto-sink.json    |   2 +-
 .../resources/connectors/camel-cxf-sink.json       |   2 +-
 .../resources/connectors/camel-cxf-source.json     |   2 +-
 .../resources/connectors/camel-cxfrs-sink.json     |   2 +-
 .../resources/connectors/camel-cxfrs-source.json   |   2 +-
 .../connectors/camel-dataformat-sink.json          |   2 +-
 .../resources/connectors/camel-direct-sink.json    |   2 +-
 .../resources/connectors/camel-direct-source.json  |   2 +-
 .../resources/connectors/camel-direct-vm-sink.json |   2 +-
 .../connectors/camel-direct-vm-source.json         |   2 +-
 .../resources/connectors/camel-disruptor-sink.json |   2 +-
 .../connectors/camel-disruptor-source.json         |   2 +-
 .../connectors/camel-disruptor-vm-sink.json        |   2 +-
 .../connectors/camel-disruptor-vm-source.json      |   2 +-
 .../resources/connectors/camel-djl-sink.json       |   2 +-
 .../resources/connectors/camel-dns-sink.json       |   2 +-
 .../resources/connectors/camel-docker-sink.json    |   2 +-
 .../resources/connectors/camel-docker-source.json  |   2 +-
 .../resources/connectors/camel-dozer-sink.json     |   2 +-
 .../resources/connectors/camel-drill-sink.json     |   2 +-
 .../resources/connectors/camel-dropbox-sink.json   |   2 +-
 .../resources/connectors/camel-dropbox-source.json |   2 +-
 .../resources/connectors/camel-ehcache-sink.json   |   2 +-
 .../resources/connectors/camel-ehcache-source.json |   2 +-
 .../connectors/camel-elasticsearch-rest-sink.json  |   2 +-
 .../resources/connectors/camel-elsql-sink.json     |   2 +-
 .../resources/connectors/camel-elsql-source.json   |   2 +-
 .../resources/connectors/camel-etcd-keys-sink.json |   2 +-
 .../connectors/camel-etcd-stats-sink.json          |   2 +-
 .../connectors/camel-etcd-stats-source.json        |   2 +-
 .../connectors/camel-etcd-watch-source.json        |   2 +-
 .../resources/connectors/camel-exec-sink.json      |   2 +-
 .../resources/connectors/camel-facebook-sink.json  |   2 +-
 .../connectors/camel-facebook-source.json          |   2 +-
 .../resources/connectors/camel-fhir-sink.json      |   2 +-
 .../resources/connectors/camel-fhir-source.json    |   2 +-
 .../resources/connectors/camel-file-sink.json      |   2 +-
 .../resources/connectors/camel-file-source.json    |   2 +-
 .../connectors/camel-file-watch-source.json        |   2 +-
 .../resources/connectors/camel-flatpack-sink.json  |   2 +-
 .../connectors/camel-flatpack-source.json          |   2 +-
 .../resources/connectors/camel-flink-sink.json     |   2 +-
 .../resources/connectors/camel-fop-sink.json       |   2 +-
 .../connectors/camel-freemarker-sink.json          |   2 +-
 .../resources/connectors/camel-ftp-sink.json       |   2 +-
 .../resources/connectors/camel-ftp-source.json     |   2 +-
 .../resources/connectors/camel-ftps-sink.json      |   2 +-
 .../resources/connectors/camel-ftps-source.json    |   2 +-
 .../resources/connectors/camel-ganglia-sink.json   |   2 +-
 .../resources/connectors/camel-geocoder-sink.json  |   2 +-
 .../resources/connectors/camel-git-sink.json       |   2 +-
 .../resources/connectors/camel-git-source.json     |   2 +-
 .../resources/connectors/camel-github-sink.json    |   2 +-
 .../resources/connectors/camel-github-source.json  |   2 +-
 .../connectors/camel-google-bigquery-sink.json     |   2 +-
 .../connectors/camel-google-bigquery-sql-sink.json |   2 +-
 .../connectors/camel-google-calendar-sink.json     |   2 +-
 .../connectors/camel-google-calendar-source.json   |   2 +-
 .../camel-google-calendar-stream-source.json       |   2 +-
 .../connectors/camel-google-drive-sink.json        |   2 +-
 .../connectors/camel-google-drive-source.json      |   2 +-
 .../connectors/camel-google-functions-sink.json    |   6 +-
 .../connectors/camel-google-mail-sink.json         |   2 +-
 .../connectors/camel-google-mail-source.json       |   2 +-
 .../camel-google-mail-stream-source.json           |   2 +-
 .../connectors/camel-google-pubsub-sink.json       |   2 +-
 .../connectors/camel-google-pubsub-source.json     |   2 +-
 .../connectors/camel-google-sheets-sink.json       |   2 +-
 .../connectors/camel-google-sheets-source.json     |   2 +-
 .../camel-google-sheets-stream-source.json         |   2 +-
 .../connectors/camel-google-storage-sink.json      |   2 +-
 .../connectors/camel-google-storage-source.json    |   2 +-
 .../resources/connectors/camel-gora-sink.json      |   2 +-
 .../resources/connectors/camel-gora-source.json    |   2 +-
 .../resources/connectors/camel-grape-sink.json     |   2 +-
 .../resources/connectors/camel-graphql-sink.json   |   2 +-
 .../resources/connectors/camel-grpc-sink.json      |   2 +-
 .../resources/connectors/camel-grpc-source.json    |   2 +-
 .../connectors/camel-guava-eventbus-sink.json      |   2 +-
 .../connectors/camel-guava-eventbus-source.json    |   2 +-
 .../camel-hazelcast-atomicvalue-sink.json          |   2 +-
 .../camel-hazelcast-instance-source.json           |   2 +-
 .../connectors/camel-hazelcast-list-sink.json      |   2 +-
 .../connectors/camel-hazelcast-list-source.json    |   2 +-
 .../connectors/camel-hazelcast-map-sink.json       |   2 +-
 .../connectors/camel-hazelcast-map-source.json     |   2 +-
 .../connectors/camel-hazelcast-multimap-sink.json  |   2 +-
 .../camel-hazelcast-multimap-source.json           |   2 +-
 .../connectors/camel-hazelcast-queue-sink.json     |   2 +-
 .../connectors/camel-hazelcast-queue-source.json   |   2 +-
 .../camel-hazelcast-replicatedmap-sink.json        |   2 +-
 .../camel-hazelcast-replicatedmap-source.json      |   2 +-
 .../camel-hazelcast-ringbuffer-sink.json           |   2 +-
 .../connectors/camel-hazelcast-seda-sink.json      |   2 +-
 .../connectors/camel-hazelcast-seda-source.json    |   2 +-
 .../connectors/camel-hazelcast-set-sink.json       |   2 +-
 .../connectors/camel-hazelcast-set-source.json     |   2 +-
 .../connectors/camel-hazelcast-topic-sink.json     |   2 +-
 .../connectors/camel-hazelcast-topic-source.json   |   2 +-
 .../resources/connectors/camel-hbase-sink.json     |   2 +-
 .../resources/connectors/camel-hbase-source.json   |   2 +-
 .../resources/connectors/camel-hdfs-sink.json      |   2 +-
 .../resources/connectors/camel-hdfs-source.json    |   2 +-
 .../resources/connectors/camel-http-sink.json      |   2 +-
 .../resources/connectors/camel-https-sink.json     |   2 +-
 .../connectors/camel-hwcloud-smn-sink.json         |   2 +-
 .../connectors/camel-iec60870-client-sink.json     |   2 +-
 .../connectors/camel-iec60870-client-source.json   |   2 +-
 .../connectors/camel-iec60870-server-sink.json     |   2 +-
 .../connectors/camel-iec60870-server-source.json   |   2 +-
 .../connectors/camel-ignite-cache-sink.json        |   2 +-
 .../connectors/camel-ignite-cache-source.json      |   2 +-
 .../connectors/camel-ignite-compute-sink.json      |   2 +-
 .../connectors/camel-ignite-events-source.json     |   2 +-
 .../connectors/camel-ignite-idgen-sink.json        |   2 +-
 .../connectors/camel-ignite-messaging-sink.json    |   2 +-
 .../connectors/camel-ignite-messaging-source.json  |   2 +-
 .../connectors/camel-ignite-queue-sink.json        |   2 +-
 .../connectors/camel-ignite-set-sink.json          |   2 +-
 .../resources/connectors/camel-imap-sink.json      |   2 +-
 .../resources/connectors/camel-imap-source.json    |   2 +-
 .../resources/connectors/camel-imaps-sink.json     |   2 +-
 .../resources/connectors/camel-imaps-source.json   |   2 +-
 .../connectors/camel-infinispan-embedded-sink.json |   2 +-
 .../camel-infinispan-embedded-source.json          |   2 +-
 .../connectors/camel-infinispan-sink.json          |   2 +-
 .../connectors/camel-infinispan-source.json        |   2 +-
 .../resources/connectors/camel-influxdb-sink.json  |   2 +-
 .../resources/connectors/camel-iota-sink.json      |   2 +-
 .../resources/connectors/camel-ipfs-sink.json      |   2 +-
 .../resources/connectors/camel-irc-sink.json       |   2 +-
 .../resources/connectors/camel-irc-source.json     |   2 +-
 .../resources/connectors/camel-ironmq-sink.json    |   2 +-
 .../resources/connectors/camel-ironmq-source.json  |   2 +-
 .../resources/connectors/camel-jbpm-sink.json      |   2 +-
 .../resources/connectors/camel-jbpm-source.json    |   2 +-
 .../resources/connectors/camel-jcache-sink.json    |   2 +-
 .../resources/connectors/camel-jcache-source.json  |   2 +-
 .../resources/connectors/camel-jclouds-sink.json   |   2 +-
 .../resources/connectors/camel-jclouds-source.json |   2 +-
 .../resources/connectors/camel-jcr-sink.json       |   2 +-
 .../resources/connectors/camel-jcr-source.json     |   2 +-
 .../resources/connectors/camel-jdbc-sink.json      |   2 +-
 .../resources/connectors/camel-jetty-source.json   |   2 +-
 .../connectors/camel-jgroups-raft-sink.json        |   2 +-
 .../connectors/camel-jgroups-raft-source.json      |   2 +-
 .../resources/connectors/camel-jgroups-sink.json   |   2 +-
 .../resources/connectors/camel-jgroups-source.json |   2 +-
 .../resources/connectors/camel-jing-sink.json      |   2 +-
 .../resources/connectors/camel-jira-sink.json      |   2 +-
 .../resources/connectors/camel-jira-source.json    |   2 +-
 .../resources/connectors/camel-jms-sink.json       |   2 +-
 .../resources/connectors/camel-jms-source.json     |   2 +-
 .../resources/connectors/camel-jmx-source.json     |   2 +-
 .../resources/connectors/camel-jolt-sink.json      |   2 +-
 .../resources/connectors/camel-jooq-sink.json      |   2 +-
 .../resources/connectors/camel-jooq-source.json    |   2 +-
 .../resources/connectors/camel-jpa-sink.json       |   2 +-
 .../resources/connectors/camel-jpa-source.json     |   2 +-
 .../resources/connectors/camel-jslt-sink.json      |   2 +-
 .../connectors/camel-json-validator-sink.json      |   2 +-
 .../resources/connectors/camel-jsonata-sink.json   |   2 +-
 .../resources/connectors/camel-jt400-sink.json     |   2 +-
 .../resources/connectors/camel-jt400-source.json   |   2 +-
 .../resources/connectors/camel-kafka-sink.json     |   2 +-
 .../resources/connectors/camel-kafka-source.json   |   4 +-
 .../resources/connectors/camel-kamelet-sink.json   |   2 +-
 .../resources/connectors/camel-kamelet-source.json |   2 +-
 .../camel-kubernetes-config-maps-sink.json         |   2 +-
 .../camel-kubernetes-custom-resources-sink.json    |   2 +-
 .../camel-kubernetes-custom-resources-source.json  |   2 +-
 .../camel-kubernetes-deployments-sink.json         |   2 +-
 .../camel-kubernetes-deployments-source.json       |   2 +-
 .../connectors/camel-kubernetes-hpa-sink.json      |   2 +-
 .../connectors/camel-kubernetes-hpa-source.json    |   2 +-
 .../connectors/camel-kubernetes-job-sink.json      |   2 +-
 .../connectors/camel-kubernetes-job-source.json    |   2 +-
 .../camel-kubernetes-namespaces-sink.json          |   2 +-
 .../camel-kubernetes-namespaces-source.json        |   2 +-
 .../connectors/camel-kubernetes-nodes-sink.json    |   2 +-
 .../connectors/camel-kubernetes-nodes-source.json  |   2 +-
 ...-kubernetes-persistent-volumes-claims-sink.json |   2 +-
 .../camel-kubernetes-persistent-volumes-sink.json  |   2 +-
 .../connectors/camel-kubernetes-pods-sink.json     |   2 +-
 .../connectors/camel-kubernetes-pods-source.json   |   2 +-
 ...el-kubernetes-replication-controllers-sink.json |   2 +-
 ...-kubernetes-replication-controllers-source.json |   2 +-
 .../camel-kubernetes-resources-quota-sink.json     |   2 +-
 .../connectors/camel-kubernetes-secrets-sink.json  |   2 +-
 .../camel-kubernetes-service-accounts-sink.json    |   2 +-
 .../connectors/camel-kubernetes-services-sink.json |   2 +-
 .../camel-kubernetes-services-source.json          |   2 +-
 .../resources/connectors/camel-kudu-sink.json      |   2 +-
 .../resources/connectors/camel-language-sink.json  |   2 +-
 .../resources/connectors/camel-ldap-sink.json      |   2 +-
 .../resources/connectors/camel-ldif-sink.json      |   2 +-
 .../resources/connectors/camel-log-sink.json       |   2 +-
 .../resources/connectors/camel-lpr-sink.json       |   2 +-
 .../resources/connectors/camel-lucene-sink.json    |   2 +-
 .../connectors/camel-lumberjack-source.json        |   2 +-
 .../resources/connectors/camel-master-source.json  |   2 +-
 .../resources/connectors/camel-metrics-sink.json   |   2 +-
 .../connectors/camel-micrometer-sink.json          |   2 +-
 .../camel-microprofile-metrics-sink.json           |   2 +-
 .../connectors/camel-milo-client-sink.json         |   2 +-
 .../connectors/camel-milo-client-source.json       |   2 +-
 .../connectors/camel-milo-server-sink.json         |   2 +-
 .../connectors/camel-milo-server-source.json       |   2 +-
 .../resources/connectors/camel-mina-sink.json      |   2 +-
 .../resources/connectors/camel-mina-source.json    |   2 +-
 .../resources/connectors/camel-minio-sink.json     |   2 +-
 .../resources/connectors/camel-minio-source.json   |   2 +-
 .../resources/connectors/camel-mllp-sink.json      |   2 +-
 .../resources/connectors/camel-mllp-source.json    |   2 +-
 .../connectors/camel-mongodb-gridfs-sink.json      |   2 +-
 .../connectors/camel-mongodb-gridfs-source.json    |   2 +-
 .../resources/connectors/camel-mongodb-sink.json   |   2 +-
 .../resources/connectors/camel-mongodb-source.json |   2 +-
 .../resources/connectors/camel-msv-sink.json       |   2 +-
 .../resources/connectors/camel-mustache-sink.json  |   2 +-
 .../resources/connectors/camel-mvel-sink.json      |   2 +-
 .../connectors/camel-mybatis-bean-sink.json        |   2 +-
 .../resources/connectors/camel-mybatis-sink.json   |   2 +-
 .../resources/connectors/camel-mybatis-source.json |   2 +-
 .../resources/connectors/camel-nagios-sink.json    |   2 +-
 .../resources/connectors/camel-nats-sink.json      |   2 +-
 .../resources/connectors/camel-nats-source.json    |   2 +-
 .../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   |   2 +-
 .../resources/connectors/camel-nitrite-source.json |   2 +-
 .../resources/connectors/camel-nsq-sink.json       |   2 +-
 .../resources/connectors/camel-nsq-source.json     |   2 +-
 .../resources/connectors/camel-oaipmh-sink.json    |   2 +-
 .../resources/connectors/camel-oaipmh-source.json  |   2 +-
 .../resources/connectors/camel-olingo2-sink.json   |   2 +-
 .../resources/connectors/camel-olingo2-source.json |   2 +-
 .../resources/connectors/camel-olingo4-sink.json   |   2 +-
 .../resources/connectors/camel-olingo4-source.json |   2 +-
 .../camel-openshift-build-configs-sink.json        |   2 +-
 .../connectors/camel-openshift-builds-sink.json    |   2 +-
 .../connectors/camel-openstack-cinder-sink.json    |   2 +-
 .../connectors/camel-openstack-glance-sink.json    |   2 +-
 .../connectors/camel-openstack-keystone-sink.json  |   2 +-
 .../connectors/camel-openstack-neutron-sink.json   |   2 +-
 .../connectors/camel-openstack-nova-sink.json      |   2 +-
 .../connectors/camel-openstack-swift-sink.json     |   2 +-
 .../connectors/camel-optaplanner-sink.json         |   2 +-
 .../connectors/camel-optaplanner-source.json       |   2 +-
 .../connectors/camel-paho-mqtt5-sink.json          |   2 +-
 .../connectors/camel-paho-mqtt5-source.json        |   2 +-
 .../resources/connectors/camel-paho-sink.json      |   2 +-
 .../resources/connectors/camel-paho-source.json    |   2 +-
 .../resources/connectors/camel-pdf-sink.json       |   2 +-
 .../camel-pg-replication-slot-source.json          |   2 +-
 .../resources/connectors/camel-pgevent-sink.json   |   2 +-
 .../resources/connectors/camel-pgevent-source.json |   2 +-
 .../connectors/camel-platform-http-source.json     |   2 +-
 .../resources/connectors/camel-pop3-sink.json      |   2 +-
 .../resources/connectors/camel-pop3-source.json    |   2 +-
 .../resources/connectors/camel-pop3s-sink.json     |   2 +-
 .../resources/connectors/camel-pop3s-source.json   |   2 +-
 .../resources/connectors/camel-pubnub-sink.json    |   2 +-
 .../resources/connectors/camel-pubnub-source.json  |   2 +-
 .../resources/connectors/camel-pulsar-sink.json    |   2 +-
 .../resources/connectors/camel-pulsar-source.json  |   2 +-
 .../resources/connectors/camel-quartz-source.json  |   2 +-
 .../resources/connectors/camel-quickfix-sink.json  |   2 +-
 .../connectors/camel-quickfix-source.json          |   2 +-
 .../resources/connectors/camel-rabbitmq-sink.json  |   2 +-
 .../connectors/camel-rabbitmq-source.json          |   2 +-
 .../connectors/camel-reactive-streams-sink.json    |   2 +-
 .../connectors/camel-reactive-streams-source.json  |   2 +-
 .../connectors/camel-rest-api-source.json          |   2 +-
 .../connectors/camel-rest-openapi-sink.json        |   2 +-
 .../resources/connectors/camel-rest-sink.json      |   2 +-
 .../resources/connectors/camel-rest-source.json    |   2 +-
 .../connectors/camel-rest-swagger-sink.json        |   2 +-
 .../resources/connectors/camel-resteasy-sink.json  |   2 +-
 .../connectors/camel-resteasy-source.json          |   2 +-
 .../resources/connectors/camel-rss-source.json     |   2 +-
 .../resources/connectors/camel-saga-sink.json      |   2 +-
 .../connectors/camel-salesforce-sink.json          |  23 +-
 .../connectors/camel-salesforce-source.json        |   2 +-
 .../connectors/camel-sap-netweaver-sink.json       |   2 +-
 .../connectors/camel-scheduler-source.json         |   2 +-
 .../connectors/camel-schematron-sink.json          |   2 +-
 .../resources/connectors/camel-scp-sink.json       |   2 +-
 .../resources/connectors/camel-seda-sink.json      |   2 +-
 .../resources/connectors/camel-seda-source.json    |   2 +-
 .../resources/connectors/camel-service-source.json |   2 +-
 .../connectors/camel-servicenow-sink.json          |   2 +-
 .../resources/connectors/camel-servlet-source.json |   2 +-
 .../resources/connectors/camel-sftp-sink.json      |   2 +-
 .../resources/connectors/camel-sftp-source.json    |   2 +-
 .../resources/connectors/camel-sip-sink.json       |   2 +-
 .../resources/connectors/camel-sip-source.json     |   2 +-
 .../resources/connectors/camel-sips-sink.json      |   2 +-
 .../resources/connectors/camel-sips-source.json    |   2 +-
 .../resources/connectors/camel-sjms-sink.json      |   2 +-
 .../resources/connectors/camel-sjms-source.json    |   2 +-
 .../resources/connectors/camel-sjms2-sink.json     |   2 +-
 .../resources/connectors/camel-sjms2-source.json   |   2 +-
 .../resources/connectors/camel-slack-sink.json     |   2 +-
 .../resources/connectors/camel-slack-source.json   |   2 +-
 .../resources/connectors/camel-smpp-sink.json      |   2 +-
 .../resources/connectors/camel-smpp-source.json    |   2 +-
 .../resources/connectors/camel-smpps-sink.json     |   2 +-
 .../resources/connectors/camel-smpps-source.json   |   2 +-
 .../resources/connectors/camel-smtp-sink.json      |   2 +-
 .../resources/connectors/camel-smtp-source.json    |   2 +-
 .../resources/connectors/camel-smtps-sink.json     |   2 +-
 .../resources/connectors/camel-smtps-source.json   |   2 +-
 .../resources/connectors/camel-snmp-sink.json      |   2 +-
 .../resources/connectors/camel-snmp-source.json    |   2 +-
 .../resources/connectors/camel-solr-sink.json      |   2 +-
 .../resources/connectors/camel-solrCloud-sink.json |   2 +-
 .../resources/connectors/camel-solrs-sink.json     |   2 +-
 .../resources/connectors/camel-soroush-sink.json   |   2 +-
 .../resources/connectors/camel-soroush-source.json |   2 +-
 .../resources/connectors/camel-spark-sink.json     |   2 +-
 .../connectors/camel-splunk-hec-sink.json          |   2 +-
 .../resources/connectors/camel-splunk-sink.json    |   2 +-
 .../resources/connectors/camel-splunk-source.json  |   2 +-
 .../connectors/camel-spring-batch-sink.json        |   2 +-
 .../connectors/camel-spring-event-sink.json        |   2 +-
 .../connectors/camel-spring-event-source.json      |   2 +-
 .../connectors/camel-spring-integration-sink.json  |   2 +-
 .../camel-spring-integration-source.json           |   2 +-
 .../connectors/camel-spring-ldap-sink.json         |   2 +-
 .../connectors/camel-spring-rabbitmq-sink.json     |   2 +-
 .../connectors/camel-spring-rabbitmq-source.json   |   2 +-
 .../connectors/camel-spring-redis-sink.json        |   2 +-
 .../connectors/camel-spring-redis-source.json      |   2 +-
 .../resources/connectors/camel-spring-ws-sink.json |   2 +-
 .../connectors/camel-spring-ws-source.json         |   2 +-
 .../resources/connectors/camel-sql-sink.json       |   2 +-
 .../resources/connectors/camel-sql-source.json     |   2 +-
 .../connectors/camel-sql-stored-sink.json          |   2 +-
 .../resources/connectors/camel-ssh-sink.json       |   2 +-
 .../resources/connectors/camel-ssh-source.json     |   2 +-
 .../resources/connectors/camel-stax-sink.json      |   2 +-
 .../resources/connectors/camel-stitch-sink.json    |   2 +-
 .../resources/connectors/camel-stomp-sink.json     |   2 +-
 .../resources/connectors/camel-stomp-source.json   |   2 +-
 .../resources/connectors/camel-stream-sink.json    |   2 +-
 .../resources/connectors/camel-stream-source.json  |   2 +-
 .../connectors/camel-string-template-sink.json     |   2 +-
 .../resources/connectors/camel-stub-sink.json      |   2 +-
 .../resources/connectors/camel-stub-source.json    |   2 +-
 .../resources/connectors/camel-telegram-sink.json  |   2 +-
 .../connectors/camel-telegram-source.json          |   2 +-
 .../resources/connectors/camel-thrift-sink.json    |   2 +-
 .../resources/connectors/camel-thrift-source.json  |   2 +-
 .../resources/connectors/camel-tika-sink.json      |   2 +-
 .../resources/connectors/camel-timer-source.json   |   2 +-
 .../resources/connectors/camel-twilio-sink.json    |   2 +-
 .../resources/connectors/camel-twilio-source.json  |   2 +-
 .../camel-twitter-directmessage-sink.json          |   2 +-
 .../camel-twitter-directmessage-source.json        |   2 +-
 .../connectors/camel-twitter-search-sink.json      |   2 +-
 .../connectors/camel-twitter-search-source.json    |   2 +-
 .../connectors/camel-twitter-timeline-sink.json    |   2 +-
 .../connectors/camel-twitter-timeline-source.json  |   2 +-
 .../resources/connectors/camel-undertow-sink.json  |   2 +-
 .../connectors/camel-undertow-source.json          |   2 +-
 .../resources/connectors/camel-validator-sink.json |   2 +-
 .../resources/connectors/camel-velocity-sink.json  |   2 +-
 .../connectors/camel-vertx-http-sink.json          |   2 +-
 .../connectors/camel-vertx-kafka-sink.json         |   2 +-
 .../connectors/camel-vertx-kafka-source.json       |   2 +-
 .../resources/connectors/camel-vertx-sink.json     |   2 +-
 .../resources/connectors/camel-vertx-source.json   |   2 +-
 .../connectors/camel-vertx-websocket-sink.json     |   2 +-
 .../connectors/camel-vertx-websocket-source.json   |   2 +-
 .../resources/connectors/camel-vm-sink.json        |   2 +-
 .../resources/connectors/camel-vm-source.json      |   2 +-
 .../resources/connectors/camel-weather-sink.json   |   2 +-
 .../resources/connectors/camel-weather-source.json |   2 +-
 .../resources/connectors/camel-web3j-sink.json     |   2 +-
 .../resources/connectors/camel-web3j-source.json   |   2 +-
 .../resources/connectors/camel-webhook-source.json |   2 +-
 .../connectors/camel-websocket-jsr356-sink.json    |   2 +-
 .../connectors/camel-websocket-jsr356-source.json  |   2 +-
 .../resources/connectors/camel-websocket-sink.json |   2 +-
 .../connectors/camel-websocket-source.json         |   2 +-
 .../resources/connectors/camel-weka-sink.json      |   2 +-
 .../resources/connectors/camel-wordpress-sink.json |   2 +-
 .../connectors/camel-wordpress-source.json         |   2 +-
 .../resources/connectors/camel-workday-sink.json   |   2 +-
 .../resources/connectors/camel-xchange-sink.json   |   2 +-
 .../resources/connectors/camel-xj-sink.json        |   2 +-
 .../connectors/camel-xmlsecurity-sign-sink.json    |   2 +-
 .../connectors/camel-xmlsecurity-verify-sink.json  |   2 +-
 .../resources/connectors/camel-xmpp-sink.json      |   2 +-
 .../resources/connectors/camel-xmpp-source.json    |   2 +-
 .../resources/connectors/camel-xquery-sink.json    |   2 +-
 .../resources/connectors/camel-xquery-source.json  |   2 +-
 .../connectors/camel-xslt-saxon-sink.json          |   2 +-
 .../resources/connectors/camel-xslt-sink.json      |   2 +-
 .../resources/connectors/camel-yammer-sink.json    |   2 +-
 .../resources/connectors/camel-yammer-source.json  |   2 +-
 .../resources/connectors/camel-zendesk-sink.json   |   2 +-
 .../resources/connectors/camel-zendesk-source.json |   2 +-
 .../connectors/camel-zookeeper-master-source.json  |   2 +-
 .../resources/connectors/camel-zookeeper-sink.json |   2 +-
 .../connectors/camel-zookeeper-source.json         |   2 +-
 connectors/camel-activemq-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-activemq-sink.json   |   2 +-
 .../generated/resources/camel-activemq-source.json |   2 +-
 connectors/camel-ahc-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-ahc-sink.json    |   2 +-
 connectors/camel-ahc-ws-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-ahc-ws-sink.json |   2 +-
 .../generated/resources/camel-ahc-ws-source.json   |   2 +-
 connectors/camel-ahc-wss-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-ahc-wss-sink.json    |   2 +-
 .../generated/resources/camel-ahc-wss-source.json  |   2 +-
 connectors/camel-amqp-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-amqp-sink.json   |   2 +-
 .../src/generated/resources/camel-amqp-source.json |   2 +-
 connectors/camel-apns-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-apns-sink.json   |   2 +-
 .../src/generated/resources/camel-apns-source.json |   2 +-
 connectors/camel-arangodb-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-arangodb-sink.json   |   2 +-
 connectors/camel-as2-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-as2-sink.json    |   2 +-
 .../src/generated/resources/camel-as2-source.json  |   2 +-
 connectors/camel-asterisk-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-asterisk-sink.json   |   2 +-
 .../generated/resources/camel-asterisk-source.json |   2 +-
 connectors/camel-atlasmap-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-atlasmap-sink.json   |   2 +-
 connectors/camel-atmos-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-atmos-sink.json  |   2 +-
 .../generated/resources/camel-atmos-source.json    |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-atmosphere-websocket-sink.json |   2 +-
 .../camel-atmosphere-websocket-source.json         |   2 +-
 connectors/camel-atom-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-atom-source.json |   2 +-
 .../camel-atomix-map-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-atomix-map-sink.json |   2 +-
 .../resources/camel-atomix-map-source.json         |   2 +-
 .../camel-atomix-messaging-kafka-connector/pom.xml |   2 +-
 .../resources/camel-atomix-messaging-sink.json     |   2 +-
 .../resources/camel-atomix-messaging-source.json   |   2 +-
 .../camel-atomix-multimap-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-atomix-multimap-sink.json      |   2 +-
 .../camel-atomix-queue-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-atomix-queue-sink.json         |   2 +-
 .../resources/camel-atomix-queue-source.json       |   2 +-
 .../camel-atomix-set-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-atomix-set-sink.json |   2 +-
 .../resources/camel-atomix-set-source.json         |   2 +-
 .../camel-atomix-value-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-atomix-value-sink.json         |   2 +-
 .../resources/camel-atomix-value-source.json       |   2 +-
 connectors/camel-avro-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-avro-sink.json   |   2 +-
 .../src/generated/resources/camel-avro-source.json |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-aws-secrets-manager-sink.json  |  12 +-
 ...l-aws-secrets-manager-kafka-sink-connector.adoc |   4 +-
 .../CamelAwssecretsmanagerSinkConnector.properties |   4 +-
 .../CamelAwssecretsmanagerSinkConnectorConfig.java |   4 +-
 .../camel-aws2-athena-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-aws2-athena-sink.json          |   2 +-
 connectors/camel-aws2-cw-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-aws2-cw-sink.json    |   2 +-
 connectors/camel-aws2-ddb-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-ddb-sink.json   |   2 +-
 .../camel-aws2-ddbstream-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-aws2-ddbstream-source.json     |   2 +-
 connectors/camel-aws2-ec2-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-ec2-sink.json   |   2 +-
 connectors/camel-aws2-ecs-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-ecs-sink.json   |   2 +-
 connectors/camel-aws2-eks-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-eks-sink.json   |   2 +-
 .../camel-aws2-eventbridge-kafka-connector/pom.xml |   2 +-
 .../resources/camel-aws2-eventbridge-sink.json     |   2 +-
 connectors/camel-aws2-iam-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-iam-sink.json   |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-aws2-kinesis-firehose-sink.json          |  16 +-
 ...aws2-kinesis-firehose-kafka-sink-connector.adoc |   4 +-
 ...amelAws2kinesisfirehoseSinkConnectorConfig.java |   8 +
 .../camel-aws2-kinesis-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-aws2-kinesis-sink.json         |  16 +-
 .../resources/camel-aws2-kinesis-source.json       |  16 +-
 .../camel-aws2-kinesis-kafka-sink-connector.adoc   |   4 +-
 .../camel-aws2-kinesis-kafka-source-connector.adoc |   4 +-
 .../CamelAws2kinesisSinkConnectorConfig.java       |   8 +
 .../CamelAws2kinesisSourceConnectorConfig.java     |   8 +
 connectors/camel-aws2-kms-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-kms-sink.json   |   2 +-
 .../camel-aws2-lambda-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-aws2-lambda-sink.json          |   2 +-
 connectors/camel-aws2-mq-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-aws2-mq-sink.json    |   2 +-
 connectors/camel-aws2-msk-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-msk-sink.json   |   2 +-
 connectors/camel-aws2-s3-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-aws2-s3-sink.json    |  78 ++-
 .../generated/resources/camel-aws2-s3-source.json  |   2 +-
 .../docs/camel-aws2-s3-kafka-sink-connector.adoc   |  12 +-
 .../aws2s3/CamelAws2s3SinkConnectorConfig.java     |  40 ++
 connectors/camel-aws2-ses-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-ses-sink.json   |   2 +-
 connectors/camel-aws2-sns-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-sns-sink.json   |   2 +-
 connectors/camel-aws2-sqs-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-sqs-sink.json   |   2 +-
 .../generated/resources/camel-aws2-sqs-source.json |   2 +-
 connectors/camel-aws2-sts-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-aws2-sts-sink.json   |   2 +-
 .../camel-aws2-translate-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-aws2-translate-sink.json       |   2 +-
 .../camel-azure-eventhubs-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-azure-eventhubs-sink.json      |   2 +-
 .../resources/camel-azure-eventhubs-source.json    |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-azure-storage-blob-sink.json   |   2 +-
 .../resources/camel-azure-storage-blob-source.json |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-azure-storage-datalake-sink.json         |   2 +-
 .../camel-azure-storage-datalake-source.json       |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-azure-storage-queue-sink.json  |   2 +-
 .../camel-azure-storage-queue-source.json          |   2 +-
 connectors/camel-bean-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-bean-sink.json   |   2 +-
 connectors/camel-beanstalk-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-beanstalk-sink.json  |   2 +-
 .../resources/camel-beanstalk-source.json          |   2 +-
 connectors/camel-box-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-box-sink.json    |   2 +-
 .../src/generated/resources/camel-box-source.json  |   2 +-
 connectors/camel-braintree-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-braintree-sink.json  |   2 +-
 .../camel-caffeine-cache-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-caffeine-cache-sink.json       |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-caffeine-loadcache-sink.json   |   2 +-
 .../camel-chatscript-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-chatscript-sink.json |   2 +-
 connectors/camel-chunk-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-chunk-sink.json  |   2 +-
 connectors/camel-cm-sms-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-cm-sms-sink.json |   2 +-
 connectors/camel-cmis-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-cmis-sink.json   |   2 +-
 .../src/generated/resources/camel-cmis-source.json |   2 +-
 connectors/camel-coap-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-coap-sink.json   |   2 +-
 .../src/generated/resources/camel-coap-source.json |   2 +-
 connectors/camel-coap-tcp-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-coap+tcp-sink.json   |   2 +-
 .../generated/resources/camel-coap+tcp-source.json |   2 +-
 connectors/camel-coaps-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-coaps-sink.json  |   2 +-
 .../generated/resources/camel-coaps-source.json    |   2 +-
 connectors/camel-coaps-tcp-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-coaps+tcp-sink.json  |   2 +-
 .../resources/camel-coaps+tcp-source.json          |   2 +-
 connectors/camel-cometd-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-cometd-sink.json |   2 +-
 .../generated/resources/camel-cometd-source.json   |   2 +-
 connectors/camel-cometds-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-cometds-sink.json    |   2 +-
 .../generated/resources/camel-cometds-source.json  |   2 +-
 connectors/camel-consul-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-consul-sink.json |   2 +-
 .../generated/resources/camel-consul-source.json   |   2 +-
 .../camel-controlbus-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-controlbus-sink.json |   2 +-
 connectors/camel-corda-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-corda-sink.json  |   2 +-
 .../generated/resources/camel-corda-source.json    |   2 +-
 connectors/camel-couchbase-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-couchbase-sink.json  |   2 +-
 .../resources/camel-couchbase-source.json          |   2 +-
 connectors/camel-couchdb-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-couchdb-sink.json    |   2 +-
 .../generated/resources/camel-couchdb-source.json  |   2 +-
 connectors/camel-cql-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-cql-sink.json    |   2 +-
 .../src/generated/resources/camel-cql-source.json  |   2 +-
 connectors/camel-cron-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-cron-source.json |   2 +-
 .../camel-crypto-cms-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-crypto-cms-sink.json |   2 +-
 connectors/camel-crypto-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-crypto-sink.json |   2 +-
 connectors/camel-cxf-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-cxf-sink.json    |   2 +-
 .../src/generated/resources/camel-cxf-source.json  |   2 +-
 connectors/camel-cxfrs-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-cxfrs-sink.json  |   2 +-
 .../generated/resources/camel-cxfrs-source.json    |   2 +-
 .../camel-dataformat-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-dataformat-sink.json |   2 +-
 connectors/camel-direct-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-direct-sink.json |   2 +-
 .../generated/resources/camel-direct-source.json   |   2 +-
 connectors/camel-direct-vm-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-direct-vm-sink.json  |   2 +-
 .../resources/camel-direct-vm-source.json          |   2 +-
 connectors/camel-disruptor-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-disruptor-sink.json  |   2 +-
 .../resources/camel-disruptor-source.json          |   2 +-
 .../camel-disruptor-vm-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-disruptor-vm-sink.json         |   2 +-
 .../resources/camel-disruptor-vm-source.json       |   2 +-
 connectors/camel-djl-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-djl-sink.json    |   2 +-
 connectors/camel-dns-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-dns-sink.json    |   2 +-
 connectors/camel-docker-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-docker-sink.json |   2 +-
 .../generated/resources/camel-docker-source.json   |   2 +-
 connectors/camel-dozer-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-dozer-sink.json  |   2 +-
 connectors/camel-drill-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-drill-sink.json  |   2 +-
 connectors/camel-dropbox-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-dropbox-sink.json    |   2 +-
 .../generated/resources/camel-dropbox-source.json  |   2 +-
 connectors/camel-ehcache-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-ehcache-sink.json    |   2 +-
 .../generated/resources/camel-ehcache-source.json  |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-elasticsearch-rest-sink.json   |   2 +-
 connectors/camel-elsql-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-elsql-sink.json  |   2 +-
 .../generated/resources/camel-elsql-source.json    |   2 +-
 connectors/camel-elytron-kafka-connector/pom.xml   |   2 +-
 connectors/camel-etcd-keys-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-etcd-keys-sink.json  |   2 +-
 .../camel-etcd-stats-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-etcd-stats-sink.json |   2 +-
 .../resources/camel-etcd-stats-source.json         |   2 +-
 .../camel-etcd-watch-kafka-connector/pom.xml       |   2 +-
 .../resources/camel-etcd-watch-source.json         |   2 +-
 connectors/camel-exec-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-exec-sink.json   |   2 +-
 connectors/camel-facebook-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-facebook-sink.json   |   2 +-
 .../generated/resources/camel-facebook-source.json |   2 +-
 connectors/camel-fhir-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-fhir-sink.json   |   2 +-
 .../src/generated/resources/camel-fhir-source.json |   2 +-
 connectors/camel-file-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-file-sink.json   |   2 +-
 .../src/generated/resources/camel-file-source.json |   2 +-
 .../camel-file-watch-kafka-connector/pom.xml       |   2 +-
 .../resources/camel-file-watch-source.json         |   2 +-
 connectors/camel-flatpack-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-flatpack-sink.json   |   2 +-
 .../generated/resources/camel-flatpack-source.json |   2 +-
 connectors/camel-flink-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-flink-sink.json  |   2 +-
 connectors/camel-fop-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-fop-sink.json    |   2 +-
 .../camel-freemarker-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-freemarker-sink.json |   2 +-
 connectors/camel-ftp-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-ftp-sink.json    |   2 +-
 .../src/generated/resources/camel-ftp-source.json  |   2 +-
 connectors/camel-ftps-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-ftps-sink.json   |   2 +-
 .../src/generated/resources/camel-ftps-source.json |   2 +-
 connectors/camel-ganglia-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-ganglia-sink.json    |   2 +-
 connectors/camel-geocoder-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-geocoder-sink.json   |   2 +-
 connectors/camel-git-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-git-sink.json    |   2 +-
 .../src/generated/resources/camel-git-source.json  |   2 +-
 connectors/camel-github-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-github-sink.json |   2 +-
 .../generated/resources/camel-github-source.json   |   2 +-
 .../camel-google-bigquery-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-google-bigquery-sink.json      |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-google-bigquery-sql-sink.json  |   2 +-
 .../camel-google-calendar-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-google-calendar-sink.json      |   2 +-
 .../resources/camel-google-calendar-source.json    |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-google-calendar-stream-source.json       |   2 +-
 .../camel-google-drive-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-google-drive-sink.json         |   2 +-
 .../resources/camel-google-drive-source.json       |   2 +-
 .../camel-google-functions-kafka-connector/pom.xml |   2 +-
 .../resources/camel-google-functions-sink.json     |   6 +-
 ...amel-google-functions-kafka-sink-connector.adoc |   6 +-
 .../camel-google-mail-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-google-mail-sink.json          |   2 +-
 .../resources/camel-google-mail-source.json        |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-google-mail-stream-source.json |   2 +-
 .../camel-google-pubsub-kafka-connector/pom.xml    |   2 +-
 .../resources/camel-google-pubsub-sink.json        |   2 +-
 .../resources/camel-google-pubsub-source.json      |   2 +-
 .../camel-google-sheets-kafka-connector/pom.xml    |   2 +-
 .../resources/camel-google-sheets-sink.json        |   2 +-
 .../resources/camel-google-sheets-source.json      |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-google-sheets-stream-source.json         |   2 +-
 .../camel-google-storage-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-google-storage-sink.json       |   2 +-
 .../resources/camel-google-storage-source.json     |   2 +-
 .../camel-google-storage-kafka-sink-connector.adoc |   4 +
 ...amel-google-storage-kafka-source-connector.adoc |   4 +
 connectors/camel-gora-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-gora-sink.json   |   2 +-
 .../src/generated/resources/camel-gora-source.json |   2 +-
 connectors/camel-grape-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-grape-sink.json  |   2 +-
 connectors/camel-graphql-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-graphql-sink.json    |   2 +-
 connectors/camel-grpc-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-grpc-sink.json   |   2 +-
 .../src/generated/resources/camel-grpc-source.json |   2 +-
 .../camel-guava-eventbus-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-guava-eventbus-sink.json       |   2 +-
 .../resources/camel-guava-eventbus-source.json     |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-hazelcast-atomicvalue-sink.json          |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-hazelcast-instance-source.json |   2 +-
 .../camel-hazelcast-list-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-hazelcast-list-sink.json       |   2 +-
 .../resources/camel-hazelcast-list-source.json     |   2 +-
 .../camel-hazelcast-map-kafka-connector/pom.xml    |   2 +-
 .../resources/camel-hazelcast-map-sink.json        |   2 +-
 .../resources/camel-hazelcast-map-source.json      |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-hazelcast-multimap-sink.json   |   2 +-
 .../resources/camel-hazelcast-multimap-source.json |   2 +-
 .../camel-hazelcast-queue-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-hazelcast-queue-sink.json      |   2 +-
 .../resources/camel-hazelcast-queue-source.json    |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-hazelcast-replicatedmap-sink.json        |   2 +-
 .../camel-hazelcast-replicatedmap-source.json      |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-hazelcast-ringbuffer-sink.json |   2 +-
 .../camel-hazelcast-seda-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-hazelcast-seda-sink.json       |   2 +-
 .../resources/camel-hazelcast-seda-source.json     |   2 +-
 .../camel-hazelcast-set-kafka-connector/pom.xml    |   2 +-
 .../resources/camel-hazelcast-set-sink.json        |   2 +-
 .../resources/camel-hazelcast-set-source.json      |   2 +-
 .../camel-hazelcast-topic-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-hazelcast-topic-sink.json      |   2 +-
 .../resources/camel-hazelcast-topic-source.json    |   2 +-
 connectors/camel-hbase-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-hbase-sink.json  |   2 +-
 .../generated/resources/camel-hbase-source.json    |   2 +-
 connectors/camel-hdfs-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-hdfs-sink.json   |   2 +-
 .../src/generated/resources/camel-hdfs-source.json |   2 +-
 connectors/camel-http-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-http-sink.json   |   2 +-
 connectors/camel-https-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-https-sink.json  |   2 +-
 .../camel-hwcloud-smn-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-hwcloud-smn-sink.json          |   2 +-
 .../camel-iec60870-client-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-iec60870-client-sink.json      |   2 +-
 .../resources/camel-iec60870-client-source.json    |   2 +-
 .../camel-iec60870-server-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-iec60870-server-sink.json      |   2 +-
 .../resources/camel-iec60870-server-source.json    |   2 +-
 .../camel-ignite-cache-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-ignite-cache-sink.json         |   2 +-
 .../resources/camel-ignite-cache-source.json       |   2 +-
 .../camel-ignite-compute-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-ignite-compute-sink.json       |   2 +-
 .../camel-ignite-events-kafka-connector/pom.xml    |   2 +-
 .../resources/camel-ignite-events-source.json      |   2 +-
 .../camel-ignite-idgen-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-ignite-idgen-sink.json         |   2 +-
 .../camel-ignite-messaging-kafka-connector/pom.xml |   2 +-
 .../resources/camel-ignite-messaging-sink.json     |   2 +-
 .../resources/camel-ignite-messaging-source.json   |   2 +-
 .../camel-ignite-queue-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-ignite-queue-sink.json         |   2 +-
 .../camel-ignite-set-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-ignite-set-sink.json |   2 +-
 connectors/camel-imap-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-imap-sink.json   |   2 +-
 .../src/generated/resources/camel-imap-source.json |   2 +-
 connectors/camel-imaps-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-imaps-sink.json  |   2 +-
 .../generated/resources/camel-imaps-source.json    |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-infinispan-embedded-sink.json  |   2 +-
 .../camel-infinispan-embedded-source.json          |   2 +-
 .../camel-infinispan-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-infinispan-sink.json |   2 +-
 .../resources/camel-infinispan-source.json         |   2 +-
 connectors/camel-influxdb-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-influxdb-sink.json   |   2 +-
 connectors/camel-iota-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-iota-sink.json   |   2 +-
 connectors/camel-ipfs-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-ipfs-sink.json   |   2 +-
 connectors/camel-irc-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-irc-sink.json    |   2 +-
 .../src/generated/resources/camel-irc-source.json  |   2 +-
 connectors/camel-ironmq-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-ironmq-sink.json |   2 +-
 .../generated/resources/camel-ironmq-source.json   |   2 +-
 connectors/camel-jbpm-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-jbpm-sink.json   |   2 +-
 .../src/generated/resources/camel-jbpm-source.json |   2 +-
 connectors/camel-jcache-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-jcache-sink.json |   2 +-
 .../generated/resources/camel-jcache-source.json   |   2 +-
 connectors/camel-jclouds-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-jclouds-sink.json    |   2 +-
 .../generated/resources/camel-jclouds-source.json  |   2 +-
 connectors/camel-jcr-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-jcr-sink.json    |   2 +-
 .../src/generated/resources/camel-jcr-source.json  |   2 +-
 connectors/camel-jdbc-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-jdbc-sink.json   |   2 +-
 connectors/camel-jetty-kafka-connector/pom.xml     |   2 +-
 .../generated/resources/camel-jetty-source.json    |   2 +-
 connectors/camel-jgroups-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-jgroups-sink.json    |   2 +-
 .../generated/resources/camel-jgroups-source.json  |   2 +-
 .../camel-jgroups-raft-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-jgroups-raft-sink.json         |   2 +-
 .../resources/camel-jgroups-raft-source.json       |   2 +-
 connectors/camel-jing-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-jing-sink.json   |   2 +-
 connectors/camel-jira-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-jira-sink.json   |   2 +-
 .../src/generated/resources/camel-jira-source.json |   2 +-
 connectors/camel-jms-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-jms-sink.json    |   2 +-
 .../src/generated/resources/camel-jms-source.json  |   2 +-
 connectors/camel-jmx-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-jmx-source.json  |   2 +-
 connectors/camel-jolt-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-jolt-sink.json   |   2 +-
 connectors/camel-jooq-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-jooq-sink.json   |   2 +-
 .../src/generated/resources/camel-jooq-source.json |   2 +-
 connectors/camel-jpa-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-jpa-sink.json    |   2 +-
 .../src/generated/resources/camel-jpa-source.json  |   2 +-
 connectors/camel-jslt-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-jslt-sink.json   |   2 +-
 .../camel-json-validator-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-json-validator-sink.json       |   2 +-
 connectors/camel-jsonata-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-jsonata-sink.json    |   2 +-
 connectors/camel-jt400-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-jt400-sink.json  |   2 +-
 .../generated/resources/camel-jt400-source.json    |   2 +-
 connectors/camel-kafka-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-kafka-sink.json  |   2 +-
 .../generated/resources/camel-kafka-source.json    |   4 +-
 .../docs/camel-kafka-kafka-source-connector.adoc   |   4 +-
 .../kafka/CamelKafkaSourceConnectorConfig.java     |   4 +-
 connectors/camel-kamelet-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-kamelet-sink.json    |   2 +-
 .../generated/resources/camel-kamelet-source.json  |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-kubernetes-config-maps-sink.json         |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-kubernetes-custom-resources-sink.json    |   2 +-
 .../camel-kubernetes-custom-resources-source.json  |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-kubernetes-deployments-sink.json         |   2 +-
 .../camel-kubernetes-deployments-source.json       |   2 +-
 .../camel-kubernetes-hpa-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-kubernetes-hpa-sink.json       |   2 +-
 .../resources/camel-kubernetes-hpa-source.json     |   2 +-
 .../camel-kubernetes-job-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-kubernetes-job-sink.json       |   2 +-
 .../resources/camel-kubernetes-job-source.json     |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-kubernetes-namespaces-sink.json          |   2 +-
 .../camel-kubernetes-namespaces-source.json        |   2 +-
 .../camel-kubernetes-nodes-kafka-connector/pom.xml |   2 +-
 .../resources/camel-kubernetes-nodes-sink.json     |   2 +-
 .../resources/camel-kubernetes-nodes-source.json   |   2 +-
 .../pom.xml                                        |   2 +-
 ...-kubernetes-persistent-volumes-claims-sink.json |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-kubernetes-persistent-volumes-sink.json  |   2 +-
 .../camel-kubernetes-pods-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-kubernetes-pods-sink.json      |   2 +-
 .../resources/camel-kubernetes-pods-source.json    |   2 +-
 .../pom.xml                                        |   2 +-
 ...el-kubernetes-replication-controllers-sink.json |   2 +-
 ...-kubernetes-replication-controllers-source.json |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-kubernetes-resources-quota-sink.json     |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-kubernetes-secrets-sink.json   |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-kubernetes-service-accounts-sink.json    |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-kubernetes-services-sink.json  |   2 +-
 .../camel-kubernetes-services-source.json          |   2 +-
 connectors/camel-kudu-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-kudu-sink.json   |   2 +-
 connectors/camel-language-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-language-sink.json   |   2 +-
 connectors/camel-ldap-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-ldap-sink.json   |   2 +-
 connectors/camel-ldif-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-ldif-sink.json   |   2 +-
 connectors/camel-log-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-log-sink.json    |   2 +-
 connectors/camel-lpr-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-lpr-sink.json    |   2 +-
 connectors/camel-lucene-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-lucene-sink.json |   2 +-
 .../camel-lumberjack-kafka-connector/pom.xml       |   2 +-
 .../resources/camel-lumberjack-source.json         |   2 +-
 connectors/camel-master-kafka-connector/pom.xml    |   2 +-
 .../generated/resources/camel-master-source.json   |   2 +-
 connectors/camel-metrics-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-metrics-sink.json    |   2 +-
 .../camel-micrometer-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-micrometer-sink.json |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-microprofile-metrics-sink.json |   2 +-
 .../camel-milo-client-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-milo-client-sink.json          |   2 +-
 .../resources/camel-milo-client-source.json        |   2 +-
 .../camel-milo-server-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-milo-server-sink.json          |   2 +-
 .../resources/camel-milo-server-source.json        |   2 +-
 connectors/camel-mina-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-mina-sink.json   |   2 +-
 .../src/generated/resources/camel-mina-source.json |   2 +-
 connectors/camel-minio-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-minio-sink.json  |   2 +-
 .../generated/resources/camel-minio-source.json    |   2 +-
 connectors/camel-mllp-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-mllp-sink.json   |   2 +-
 .../src/generated/resources/camel-mllp-source.json |   2 +-
 .../camel-mongodb-gridfs-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-mongodb-gridfs-sink.json       |   2 +-
 .../resources/camel-mongodb-gridfs-source.json     |   2 +-
 connectors/camel-mongodb-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-mongodb-sink.json    |   2 +-
 .../generated/resources/camel-mongodb-source.json  |   2 +-
 connectors/camel-msv-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-msv-sink.json    |   2 +-
 connectors/camel-mustache-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-mustache-sink.json   |   2 +-
 connectors/camel-mvel-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-mvel-sink.json   |   2 +-
 .../camel-mybatis-bean-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-mybatis-bean-sink.json         |   2 +-
 connectors/camel-mybatis-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-mybatis-sink.json    |   2 +-
 .../generated/resources/camel-mybatis-source.json  |   2 +-
 connectors/camel-nagios-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-nagios-sink.json |   2 +-
 connectors/camel-nats-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-nats-sink.json   |   2 +-
 .../src/generated/resources/camel-nats-source.json |   2 +-
 .../camel-netty-http-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-netty-http-sink.json |   2 +-
 .../resources/camel-netty-http-source.json         |   2 +-
 connectors/camel-netty-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-netty-sink.json  |   2 +-
 .../generated/resources/camel-netty-source.json    |   2 +-
 connectors/camel-nitrite-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-nitrite-sink.json    |   2 +-
 .../generated/resources/camel-nitrite-source.json  |   2 +-
 connectors/camel-nsq-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-nsq-sink.json    |   2 +-
 .../src/generated/resources/camel-nsq-source.json  |   2 +-
 connectors/camel-oaipmh-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-oaipmh-sink.json |   2 +-
 .../generated/resources/camel-oaipmh-source.json   |   2 +-
 connectors/camel-olingo2-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-olingo2-sink.json    |   2 +-
 .../generated/resources/camel-olingo2-source.json  |   2 +-
 connectors/camel-olingo4-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-olingo4-sink.json    |   2 +-
 .../generated/resources/camel-olingo4-source.json  |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-openshift-build-configs-sink.json        |   2 +-
 .../camel-openshift-builds-kafka-connector/pom.xml |   2 +-
 .../resources/camel-openshift-builds-sink.json     |   2 +-
 .../camel-openstack-cinder-kafka-connector/pom.xml |   2 +-
 .../resources/camel-openstack-cinder-sink.json     |   2 +-
 .../camel-openstack-glance-kafka-connector/pom.xml |   2 +-
 .../resources/camel-openstack-glance-sink.json     |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-openstack-keystone-sink.json   |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-openstack-neutron-sink.json    |   2 +-
 .../camel-openstack-nova-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-openstack-nova-sink.json       |   2 +-
 .../camel-openstack-swift-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-openstack-swift-sink.json      |   2 +-
 .../camel-optaplanner-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-optaplanner-sink.json          |   2 +-
 .../resources/camel-optaplanner-source.json        |   2 +-
 connectors/camel-paho-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-paho-sink.json   |   2 +-
 .../src/generated/resources/camel-paho-source.json |   2 +-
 .../camel-paho-mqtt5-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-paho-mqtt5-sink.json |   2 +-
 .../resources/camel-paho-mqtt5-source.json         |   2 +-
 connectors/camel-pdf-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-pdf-sink.json    |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-pg-replication-slot-source.json          |   2 +-
 connectors/camel-pgevent-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-pgevent-sink.json    |   2 +-
 .../generated/resources/camel-pgevent-source.json  |   2 +-
 .../camel-platform-http-kafka-connector/pom.xml    |   2 +-
 .../resources/camel-platform-http-source.json      |   2 +-
 connectors/camel-pop3-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-pop3-sink.json   |   2 +-
 .../src/generated/resources/camel-pop3-source.json |   2 +-
 connectors/camel-pop3s-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-pop3s-sink.json  |   2 +-
 .../generated/resources/camel-pop3s-source.json    |   2 +-
 connectors/camel-pubnub-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-pubnub-sink.json |   2 +-
 .../generated/resources/camel-pubnub-source.json   |   2 +-
 connectors/camel-pulsar-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-pulsar-sink.json |   2 +-
 .../generated/resources/camel-pulsar-source.json   |   2 +-
 connectors/camel-quartz-kafka-connector/pom.xml    |   2 +-
 .../generated/resources/camel-quartz-source.json   |   2 +-
 connectors/camel-quickfix-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-quickfix-sink.json   |   2 +-
 .../generated/resources/camel-quickfix-source.json |   2 +-
 connectors/camel-rabbitmq-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-rabbitmq-sink.json   |   2 +-
 .../generated/resources/camel-rabbitmq-source.json |   2 +-
 .../camel-reactive-streams-kafka-connector/pom.xml |   2 +-
 .../resources/camel-reactive-streams-sink.json     |   2 +-
 .../resources/camel-reactive-streams-source.json   |   2 +-
 connectors/camel-rest-api-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-rest-api-source.json |   2 +-
 connectors/camel-rest-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-rest-sink.json   |   2 +-
 .../src/generated/resources/camel-rest-source.json |   2 +-
 .../camel-rest-openapi-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-rest-openapi-sink.json         |   2 +-
 .../camel-rest-swagger-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-rest-swagger-sink.json         |   2 +-
 connectors/camel-resteasy-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-resteasy-sink.json   |   2 +-
 .../generated/resources/camel-resteasy-source.json |   2 +-
 connectors/camel-rss-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-rss-source.json  |   2 +-
 connectors/camel-saga-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-saga-sink.json   |   2 +-
 .../camel-salesforce-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-salesforce-sink.json |  23 +-
 .../resources/camel-salesforce-source.json         |   2 +-
 .../camel-salesforce-kafka-sink-connector.adoc     |   6 +-
 .../CamelSalesforceSinkConnectorConfig.java        |  10 +-
 .../camel-sap-netweaver-kafka-connector/pom.xml    |   2 +-
 .../resources/camel-sap-netweaver-sink.json        |   2 +-
 connectors/camel-scheduler-kafka-connector/pom.xml |   2 +-
 .../resources/camel-scheduler-source.json          |   2 +-
 .../camel-schematron-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-schematron-sink.json |   2 +-
 connectors/camel-scp-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-scp-sink.json    |   2 +-
 connectors/camel-seda-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-seda-sink.json   |   2 +-
 .../src/generated/resources/camel-seda-source.json |   2 +-
 connectors/camel-service-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-service-source.json  |   2 +-
 .../camel-servicenow-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-servicenow-sink.json |   2 +-
 connectors/camel-servlet-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-servlet-source.json  |   2 +-
 connectors/camel-sftp-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-sftp-sink.json   |   2 +-
 .../src/generated/resources/camel-sftp-source.json |   2 +-
 connectors/camel-sip-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-sip-sink.json    |   2 +-
 .../src/generated/resources/camel-sip-source.json  |   2 +-
 connectors/camel-sips-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-sips-sink.json   |   2 +-
 .../src/generated/resources/camel-sips-source.json |   2 +-
 .../camel-sjms-batch-kafka-connector/pom.xml       |   2 +-
 .../camel-sjms-batch-kafka-source-connector.adoc   |   2 +
 connectors/camel-sjms-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-sjms-sink.json   |   2 +-
 .../src/generated/resources/camel-sjms-source.json |   2 +-
 connectors/camel-sjms2-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-sjms2-sink.json  |   2 +-
 .../generated/resources/camel-sjms2-source.json    |   2 +-
 connectors/camel-slack-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-slack-sink.json  |   2 +-
 .../generated/resources/camel-slack-source.json    |   2 +-
 connectors/camel-smpp-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-smpp-sink.json   |   2 +-
 .../src/generated/resources/camel-smpp-source.json |   2 +-
 connectors/camel-smpps-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-smpps-sink.json  |   2 +-
 .../generated/resources/camel-smpps-source.json    |   2 +-
 connectors/camel-smtp-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-smtp-sink.json   |   2 +-
 .../src/generated/resources/camel-smtp-source.json |   2 +-
 connectors/camel-smtps-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-smtps-sink.json  |   2 +-
 .../generated/resources/camel-smtps-source.json    |   2 +-
 connectors/camel-snmp-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-snmp-sink.json   |   2 +-
 .../src/generated/resources/camel-snmp-source.json |   2 +-
 connectors/camel-solr-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-solr-sink.json   |   2 +-
 connectors/camel-solrcloud-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-solrCloud-sink.json  |   2 +-
 connectors/camel-solrs-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-solrs-sink.json  |   2 +-
 connectors/camel-soroush-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-soroush-sink.json    |   2 +-
 .../generated/resources/camel-soroush-source.json  |   2 +-
 connectors/camel-spark-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-spark-sink.json  |   2 +-
 .../camel-splunk-hec-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-splunk-hec-sink.json |   2 +-
 connectors/camel-splunk-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-splunk-sink.json |   2 +-
 .../generated/resources/camel-splunk-source.json   |   2 +-
 .../camel-spring-batch-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-spring-batch-sink.json         |   2 +-
 .../camel-spring-event-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-spring-event-sink.json         |   2 +-
 .../resources/camel-spring-event-source.json       |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-spring-integration-sink.json   |   2 +-
 .../resources/camel-spring-integration-source.json |   2 +-
 .../camel-spring-ldap-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-spring-ldap-sink.json          |   2 +-
 .../camel-spring-rabbitmq-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-spring-rabbitmq-sink.json      |   2 +-
 .../resources/camel-spring-rabbitmq-source.json    |   2 +-
 .../camel-spring-redis-kafka-connector/pom.xml     |   2 +-
 .../resources/camel-spring-redis-sink.json         |   2 +-
 .../resources/camel-spring-redis-source.json       |   2 +-
 connectors/camel-spring-ws-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-spring-ws-sink.json  |   2 +-
 .../resources/camel-spring-ws-source.json          |   2 +-
 connectors/camel-sql-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-sql-sink.json    |   2 +-
 .../src/generated/resources/camel-sql-source.json  |   2 +-
 .../camel-sql-stored-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-sql-stored-sink.json |   2 +-
 connectors/camel-ssh-kafka-connector/pom.xml       |   2 +-
 .../src/generated/resources/camel-ssh-sink.json    |   2 +-
 .../src/generated/resources/camel-ssh-source.json  |   2 +-
 connectors/camel-stax-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-stax-sink.json   |   2 +-
 connectors/camel-stitch-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-stitch-sink.json |   2 +-
 connectors/camel-stomp-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-stomp-sink.json  |   2 +-
 .../generated/resources/camel-stomp-source.json    |   2 +-
 connectors/camel-stream-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-stream-sink.json |   2 +-
 .../generated/resources/camel-stream-source.json   |   2 +-
 .../camel-string-template-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-string-template-sink.json      |   2 +-
 connectors/camel-stub-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-stub-sink.json   |   2 +-
 .../src/generated/resources/camel-stub-source.json |   2 +-
 connectors/camel-syslog-kafka-connector/pom.xml    |   2 +-
 connectors/camel-telegram-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-telegram-sink.json   |   2 +-
 .../generated/resources/camel-telegram-source.json |   2 +-
 connectors/camel-thrift-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-thrift-sink.json |   2 +-
 .../generated/resources/camel-thrift-source.json   |   2 +-
 connectors/camel-tika-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-tika-sink.json   |   2 +-
 connectors/camel-timer-kafka-connector/pom.xml     |   2 +-
 .../generated/resources/camel-timer-source.json    |   2 +-
 connectors/camel-twilio-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-twilio-sink.json |   2 +-
 .../generated/resources/camel-twilio-source.json   |   2 +-
 .../pom.xml                                        |   2 +-
 .../camel-twitter-directmessage-sink.json          |   2 +-
 .../camel-twitter-directmessage-source.json        |   2 +-
 .../camel-twitter-search-kafka-connector/pom.xml   |   2 +-
 .../resources/camel-twitter-search-sink.json       |   2 +-
 .../resources/camel-twitter-search-source.json     |   2 +-
 .../camel-twitter-timeline-kafka-connector/pom.xml |   2 +-
 .../resources/camel-twitter-timeline-sink.json     |   2 +-
 .../resources/camel-twitter-timeline-source.json   |   2 +-
 connectors/camel-undertow-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-undertow-sink.json   |   2 +-
 .../generated/resources/camel-undertow-source.json |   2 +-
 connectors/camel-validator-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-validator-sink.json  |   2 +-
 connectors/camel-velocity-kafka-connector/pom.xml  |   2 +-
 .../generated/resources/camel-velocity-sink.json   |   2 +-
 .../camel-vertx-http-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-vertx-http-sink.json |   2 +-
 connectors/camel-vertx-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-vertx-sink.json  |   2 +-
 .../generated/resources/camel-vertx-source.json    |   2 +-
 .../camel-vertx-kafka-kafka-connector/pom.xml      |   2 +-
 .../resources/camel-vertx-kafka-sink.json          |   2 +-
 .../resources/camel-vertx-kafka-source.json        |   2 +-
 .../camel-vertx-websocket-kafka-connector/pom.xml  |   2 +-
 .../resources/camel-vertx-websocket-sink.json      |   2 +-
 .../resources/camel-vertx-websocket-source.json    |   2 +-
 connectors/camel-vm-kafka-connector/pom.xml        |   2 +-
 .../src/generated/resources/camel-vm-sink.json     |   2 +-
 .../src/generated/resources/camel-vm-source.json   |   2 +-
 connectors/camel-weather-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-weather-sink.json    |   2 +-
 .../generated/resources/camel-weather-source.json  |   2 +-
 connectors/camel-web3j-kafka-connector/pom.xml     |   2 +-
 .../src/generated/resources/camel-web3j-sink.json  |   2 +-
 .../generated/resources/camel-web3j-source.json    |   2 +-
 connectors/camel-webhook-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-webhook-source.json  |   2 +-
 .../camel-websocket-jsr356-kafka-connector/pom.xml |   2 +-
 .../resources/camel-websocket-jsr356-sink.json     |   2 +-
 .../resources/camel-websocket-jsr356-source.json   |   2 +-
 connectors/camel-websocket-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-websocket-sink.json  |   2 +-
 .../resources/camel-websocket-source.json          |   2 +-
 connectors/camel-weka-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-weka-sink.json   |   2 +-
 connectors/camel-wordpress-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-wordpress-sink.json  |   2 +-
 .../resources/camel-wordpress-source.json          |   2 +-
 connectors/camel-workday-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-workday-sink.json    |   2 +-
 connectors/camel-xchange-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-xchange-sink.json    |   2 +-
 connectors/camel-xj-kafka-connector/pom.xml        |   2 +-
 .../src/generated/resources/camel-xj-sink.json     |   2 +-
 .../camel-xmlsecurity-sign-kafka-connector/pom.xml |   2 +-
 .../resources/camel-xmlsecurity-sign-sink.json     |   2 +-
 .../pom.xml                                        |   2 +-
 .../resources/camel-xmlsecurity-verify-sink.json   |   2 +-
 connectors/camel-xmpp-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-xmpp-sink.json   |   2 +-
 .../src/generated/resources/camel-xmpp-source.json |   2 +-
 connectors/camel-xquery-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-xquery-sink.json |   2 +-
 .../generated/resources/camel-xquery-source.json   |   2 +-
 connectors/camel-xslt-kafka-connector/pom.xml      |   2 +-
 .../src/generated/resources/camel-xslt-sink.json   |   2 +-
 .../camel-xslt-saxon-kafka-connector/pom.xml       |   2 +-
 .../generated/resources/camel-xslt-saxon-sink.json |   2 +-
 connectors/camel-yammer-kafka-connector/pom.xml    |   2 +-
 .../src/generated/resources/camel-yammer-sink.json |   2 +-
 .../generated/resources/camel-yammer-source.json   |   2 +-
 connectors/camel-zendesk-kafka-connector/pom.xml   |   2 +-
 .../generated/resources/camel-zendesk-sink.json    |   2 +-
 .../generated/resources/camel-zendesk-source.json  |   2 +-
 connectors/camel-zookeeper-kafka-connector/pom.xml |   2 +-
 .../generated/resources/camel-zookeeper-sink.json  |   2 +-
 .../resources/camel-zookeeper-source.json          |   2 +-
 .../camel-zookeeper-master-kafka-connector/pom.xml |   2 +-
 .../resources/camel-zookeeper-master-source.json   |   2 +-
 connectors/pom.xml                                 |   4 +-
 core/pom.xml                                       |   2 +-
 .../apache/camel/kafkaconnector/CamelSinkTask.java |   7 +-
 distribution/pom.xml                               |   2 +-
 .../ROOT/pages/camel-compatibility-matrix.adoc     |   3 +-
 docs/modules/ROOT/pages/connectors.adoc            | 674 ++++++++++-----------
 ...l-aws-secrets-manager-kafka-sink-connector.adoc |   4 +-
 ...aws2-kinesis-firehose-kafka-sink-connector.adoc |   4 +-
 .../camel-aws2-kinesis-kafka-sink-connector.adoc   |   4 +-
 .../camel-aws2-kinesis-kafka-source-connector.adoc |   4 +-
 .../camel-aws2-s3-kafka-sink-connector.adoc        |  12 +-
 ...amel-google-functions-kafka-sink-connector.adoc |   6 +-
 .../camel-google-storage-kafka-sink-connector.adoc |   4 +
 ...amel-google-storage-kafka-source-connector.adoc |   4 +
 .../camel-kafka-kafka-source-connector.adoc        |   4 +-
 .../camel-salesforce-kafka-sink-connector.adoc     |   6 +-
 .../camel-sjms-batch-kafka-source-connector.adoc   |   2 +
 .../ROOT/pages/single-message-transform.adoc       |  23 +
 .../ROOT/pages/transformers/fieldsToHeaders.adoc   |  73 +++
 parent/pom.xml                                     |  10 +-
 pom.xml                                            |   4 +-
 tests/itests-aws-v2/pom.xml                        |   2 +-
 tests/itests-azure-storage-blob/pom.xml            |   2 +-
 tests/itests-azure-storage-queue/pom.xml           |   2 +-
 tests/itests-cassandra/pom.xml                     |   2 +-
 .../{itests-common => itests-common-http}/pom.xml  |  23 +-
 .../common/services/mockweb/MockWebService.java    | 136 +++++
 tests/itests-common/pom.xml                        |   4 +-
 .../common/BasicConnectorPropertyFactory.java      |   4 +
 .../common/ConnectorPropertyFactory.java           |   2 +-
 .../common/SinkConnectorPropertyFactory.java       |  17 +-
 .../common/SourceConnectorPropertyFactory.java     |  29 +-
 .../common/test/CamelSourceTestSupport.java        |   4 +
 .../kafkaconnector/common/utils/NetworkUtils.java  |  17 +-
 tests/itests-couchbase/pom.xml                     |   2 +-
 .../couchbase/sink/CamelSinkCouchbaseITCase.java   |   2 +
 tests/itests-cxf/pom.xml                           |   2 +-
 .../cxf/sink/CamelSinkCXFITCase.java               |   2 +-
 .../cxf/source/CamelSourceCXFITCase.java           |   6 +-
 tests/{itests-cxf => itests-cxfrs}/pom.xml         |  23 +-
 .../camel/kafkaconnector/cxfrs/Customer.java       |  79 +++
 .../cxfrs/CustomerServiceResource.java             |  44 +-
 .../cxfrs/source/CamelSourceCXFRSITCase.java       | 145 +++++
 .../source/CamelSourceCXFRSPropertyFactory.java}   |  40 +-
 .../kafkaconnector/cxfrs/source}/HelloService.java |   2 +-
 tests/itests-elasticsearch/pom.xml                 |   2 +-
 tests/itests-file/pom.xml                          |   2 +-
 tests/itests-google-pubsub/pom.xml                 |   6 +-
 .../pubsub/sink/CamelSinkGooglePubSubITCase.java   |   8 +-
 tests/itests-hdfs/pom.xml                          |   2 +-
 tests/itests-http/pom.xml                          |   2 +-
 tests/{itests-netty-http => itests-https}/pom.xml  |  22 +-
 .../https/sink/CamelHTTPSPropertyFactory.java      |  72 +++
 .../https/sink/CamelSinkHTTPSITCase.java           | 166 +++++
 .../src/test/resources/client-truststore.jks       | Bin 0 -> 844 bytes
 .../src/test/resources/server-keystore.jks         | Bin 0 -> 2134 bytes
 tests/itests-jdbc/pom.xml                          |   2 +-
 tests/itests-mongodb/pom.xml                       |   2 +-
 .../mongodb/source/CamelSourceMongoDBITCase.java   |   2 -
 tests/itests-netty-http/pom.xml                    |   9 +-
 .../sink/CamelNettyhttpPropertyFactory.java}       |  32 +-
 .../nettyhttp/sink/CamelSinkNettyhttpITCase.java   |  19 +-
 tests/itests-netty/pom.xml                         |   2 +-
 .../netty/sink/CamelSinkNettyITCase.java           |   1 -
 .../netty/source/CamelSourceNettyITCase.java       |  13 +-
 tests/itests-parent/pom.xml                        |  21 +-
 tests/itests-rabbitmq/pom.xml                      |   2 +-
 tests/itests-salesforce/pom.xml                    |   2 +-
 tests/itests-sjms2/pom.xml                         |   2 +-
 tests/itests-slack/pom.xml                         |   2 +-
 tests/itests-sql/pom.xml                           |   2 +-
 tests/itests-ssh/pom.xml                           |   2 +-
 tests/itests-syslog/pom.xml                        |   2 +-
 tests/itests-timer/pom.xml                         |   2 +-
 tests/perf-tests-rabbitmq/pom.xml                  |   2 +-
 tests/pom.xml                                      |   6 +-
 .../pom.xml                                        |   2 +-
 .../pom.xml                                        |   2 +-
 .../README.adoc                                    |  41 +-
 .../pom.xml                                        |  83 ++-
 .../maven/AbstractCamelKafkaConnectorMojo.java     |   2 +-
 .../maven/GenerateCamelKafkaConnectorsMojo.java    |  14 +-
 .../maven/GenerateCamelKafkaConnectorsMojoIT.java  | 110 ++++
 .../test_generate/pom.xml                          | 108 ++++
 .../resources/camel-kafka-connector-LICENSE.txt    |   0
 .../resources/camel-kafka-connector-NOTICE.txt     |   0
 ...mel-kafka-connector-fix-dependencies.properties |   0
 .../camel-kafka-connector-java-header.txt          |   0
 ...ector-template-example-sink-properties.template |   0
 ...tor-template-example-source-properties.template |   0
 .../test/resources}/template-connector-package.xml |   0
 .../src/test/resources}/template-connector-pom.xml |   0
 tooling/camel-kafka-connector-model/pom.xml        |   2 +-
 tooling/pom.xml                                    |  11 +-
 1514 files changed, 3809 insertions(+), 1995 deletions(-)
 create mode 100644 docs/modules/ROOT/pages/single-message-transform.adoc
 create mode 100644 docs/modules/ROOT/pages/transformers/fieldsToHeaders.adoc
 copy tests/{itests-common => itests-common-http}/pom.xml (73%)
 create mode 100644 tests/itests-common-http/src/test/java/org/apache/camel/kafkaconnector/common/services/mockweb/MockWebService.java
 copy tests/{itests-cxf => itests-cxfrs}/pom.xml (85%)
 create mode 100644 tests/itests-cxfrs/src/test/java/org/apache/camel/kafkaconnector/cxfrs/Customer.java
 copy connectors/camel-cxfrs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/cxfrs/CamelCxfrsSinkConnector.java => tests/itests-cxfrs/src/test/java/org/apache/camel/kafkaconnector/cxfrs/CustomerServiceResource.java (51%)
 create mode 100644 tests/itests-cxfrs/src/test/java/org/apache/camel/kafkaconnector/cxfrs/source/CamelSourceCXFRSITCase.java
 copy tests/{itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/source/CamelSourceCXFPropertyFactory.java => itests-cxfrs/src/test/java/org/apache/camel/kafkaconnector/cxfrs/source/CamelSourceCXFRSPropertyFactory.java} (59%)
 copy tests/{itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/common => itests-cxfrs/src/test/java/org/apache/camel/kafkaconnector/cxfrs/source}/HelloService.java (95%)
 copy tests/{itests-netty-http => itests-https}/pom.xml (79%)
 create mode 100644 tests/itests-https/src/test/java/org/apache/camel/kafkaconnector/https/sink/CamelHTTPSPropertyFactory.java
 create mode 100644 tests/itests-https/src/test/java/org/apache/camel/kafkaconnector/https/sink/CamelSinkHTTPSITCase.java
 create mode 100644 tests/itests-https/src/test/resources/client-truststore.jks
 create mode 100644 tests/itests-https/src/test/resources/server-keystore.jks
 copy tests/{itests-netty/src/test/java/org/apache/camel/kafkaconnector/netty/sink/CamelNettyPropertyFactory.java => itests-netty-http/src/test/java/org/apache/camel/kafkaconnector/nettyhttp/sink/CamelNettyhttpPropertyFactory.java} (60%)
 create mode 100644 tooling/camel-kafka-connector-generator-maven-plugin/src/test/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT.java
 create mode 100644 tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/test_generate/pom.xml
 copy tooling/camel-kafka-connector-generator-maven-plugin/src/{main => test}/resources/camel-kafka-connector-LICENSE.txt (100%)
 copy tooling/camel-kafka-connector-generator-maven-plugin/src/{main => test}/resources/camel-kafka-connector-NOTICE.txt (100%)
 copy {connectors => tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources}/camel-kafka-connector-fix-dependencies.properties (100%)
 copy {connectors => tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources}/camel-kafka-connector-java-header.txt (100%)
 copy tooling/camel-kafka-connector-generator-maven-plugin/src/{main => test}/resources/camel-kafka-connector-template-example-sink-properties.template (100%)
 copy tooling/camel-kafka-connector-generator-maven-plugin/src/{main => test}/resources/camel-kafka-connector-template-example-source-properties.template (100%)
 copy {connectors => tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources}/template-connector-package.xml (100%)
 copy {connectors => tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources}/template-connector-pom.xml (100%)