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%)
