This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/parent/com.puppycrawl.tools-checkstyle-8.29
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
omit 4958c2eac Bump checkstyle from 8.26 to 8.29 in /parent
add 2260cbfa2 Updated CHANGELOG.md
add f073d0157 Updated CHANGELOG.md
add 6412b7740 Updated to camel 3.21.x
add 0fec186f4 Updated CHANGELOG.md
add 37d240598 [maven-release-plugin] prepare release
camel-kafka-connector-3.21.0
add ba33da5b4 [maven-release-plugin] prepare for next development iteration
add 651a05b03 Updated CHANGELOG.md
add 906aa0f88 Bump actions/checkout from 3.5.3 to 3.6.0
add bf249c4ff Updated CHANGELOG.md
add c739bdf01 Updated CHANGELOG.md
add 39db0410b Updated CHANGELOG.md
add a9e9ce23c Update GH CI to use Java 17 for the Maven Archetype
integration tests
add 2ac6a25e6 Version bump to 4.0.0-SNAPSHOT to align with Camel 4
add 8f8677090 camel.version
add 54200bd7e Fixed missing version for AssertJ
add d285f5ee1 Added missing version for testcontainers on the test module
add 74fe9d78e Removed references to the ActiveMQ from the SJMS2
add c899e4939 Added missing version for testcontainers on the test module
add 4f50b55ff Fixed a circular dependency making it hard to bootstrap the
project with new Camel versions
add 8dcd32041 Bump minimum Java version to 17
add 9a61a8d1d Adjust to use Maven versions that support Java 17
add 53011223f Fixed missing commons-dbcp2 version
add 4a6b8d972 Fixed missing versions in POM files
add 2933a836d Fixes core according to Camel 4 changes
add a564a67ff Removed ActiveMQ from parent pom
add 05f848d0d Stop adding ActiveMQ as a dependency for the sjms2 connector
add 371aec36a Made the sjms2 tests compatible with Jakarta
add 60db59e1d Converted CXF to build with Jakarta 10
add 700dfebdc Removed the elasticsearch connector because it was replaced
by a new one on Camel 4
add e0bd0ebc9 Removed the RabbitMQ connector because it was removed on
Camel 4
add 25dfc504d Removed the ActiveMQ JMS connector because it was removed on
Camel 4
add 26d10166f Removed the elasticsearch connector tests because it was
replaced by a new one on Camel 4
add 4af7f564a Removed the RabbitMQ connector tests because it was removed
on Camel 4
add 0bcad736f Removed the Solr connector tests because it was removed on
Camel 4
add 0615eefa5 Removed the websocket connector because it was removed on
Camel 4
add 511ef3479 Added plexus-build-api version.
add cc8d21e2d Updated mvnw
add feba5ed05 regen after update to camel 4.0.0
add fd44e1c1a Updated slf4 and guava dependencies.
add 9016fb77a Fixed tests.
add 405eb3c6b Added back elasticsearch tests.
add 3e0b25fb4 Fixed maven connector generation plugin tests.
add 4dc6eaf7e Updated CHANGELOG.md
add e76e25830 Bump actions/checkout from 3.6.0 to 4.0.0
add e9ba05160 Updated CHANGELOG.md
add 04a797925 Add a Deploy Action for Camel-Kafka-connector on main
add 689a363a1 Jenkinsfile.deploy file, let's skip tests
new ded9054b2 Bump checkstyle from 8.26 to 8.29 in /parent
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 (4958c2eac)
\
N -- N -- N
refs/heads/dependabot/maven/parent/com.puppycrawl.tools-checkstyle-8.29
(ded9054b2)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/asf-snapshots-deploy.yml | 4 +-
.github/workflows/automatic-changelog-update.yml | 2 +-
.github/workflows/automatic-sync-camel-main.yml | 4 +-
.github/workflows/backport.yml | 2 +-
.github/workflows/ci-build.yml | 2 +-
.github/workflows/daily-java-next.yml | 2 +-
.github/workflows/depsreview.yaml | 2 +-
.github/workflows/maven-it.yaml | 4 +-
.mvn/wrapper/MavenWrapperDownloader.java | 117 -------
.mvn/wrapper/maven-wrapper.properties | 20 +-
CHANGELOG.md | 23 +-
Jenkinsfile.deploy | 80 +++++
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
archetypes/pom.xml | 2 +-
buildingtools/pom.xml | 2 +-
camel-kafka-connector-catalog/pom.xml | 4 +-
.../camel-aws-cloudtrail-source-source.json | 2 +-
.../connectors/camel-aws-cloudwatch-sink-sink.json | 2 +-
.../camel-aws-ddb-experimental-sink-sink.json | 4 +-
.../connectors/camel-aws-ddb-sink-sink.json | 13 +-
.../camel-aws-ddb-streams-source-source.json | 2 +-
.../connectors/camel-aws-ec2-sink-sink.json | 2 +-
.../camel-aws-eventbridge-sink-sink.json | 2 +-
.../camel-aws-kinesis-firehose-sink-sink.json | 2 +-
.../connectors/camel-aws-kinesis-sink-sink.json | 2 +-
.../camel-aws-kinesis-source-source.json | 2 +-
.../connectors/camel-aws-lambda-sink-sink.json | 2 +-
.../connectors/camel-aws-redshift-sink-sink.json | 2 +-
.../camel-aws-redshift-source-source.json | 2 +-
.../connectors/camel-aws-s3-cdc-source-source.json | 2 +-
.../camel-aws-s3-experimental-source-source.json | 2 +-
.../connectors/camel-aws-s3-sink-sink.json | 2 +-
.../connectors/camel-aws-s3-source-source.json | 9 +-
.../camel-aws-s3-streaming-upload-sink-sink.json | 2 +-
.../camel-aws-secrets-manager-sink-sink.json | 2 +-
.../connectors/camel-aws-ses-sink-sink.json | 2 +-
.../connectors/camel-aws-sns-fifo-sink-sink.json | 2 +-
.../connectors/camel-aws-sns-sink-sink.json | 2 +-
.../connectors/camel-aws-sqs-batch-sink-sink.json | 2 +-
.../connectors/camel-aws-sqs-fifo-sink-sink.json | 2 +-
.../connectors/camel-aws-sqs-sink-sink.json | 2 +-
.../connectors/camel-aws-sqs-source-source.json | 2 +-
.../resources/connectors/camel-aws2-iam-sink.json | 144 +++++---
.../resources/connectors/camel-aws2-kms-sink.json | 150 ++++----
.../connectors/camel-azure-cosmosdb-sink-sink.json | 43 +++
.../camel-azure-cosmosdb-source-source.json | 2 +-
.../camel-azure-eventhubs-sink-sink.json | 2 +-
.../camel-azure-eventhubs-source-source.json | 2 +-
.../camel-azure-functions-sink-sink.json | 2 +-
.../camel-azure-servicebus-sink-sink.json | 2 +-
.../camel-azure-servicebus-source-source.json | 4 +-
...camel-azure-storage-blob-cdc-source-source.json | 6 +-
...zure-storage-blob-changefeed-source-source.json | 9 +-
.../camel-azure-storage-blob-sink-sink.json | 11 +-
.../camel-azure-storage-blob-source-source.json | 16 +-
.../camel-azure-storage-datalake-sink-sink.json | 43 +++
...camel-azure-storage-datalake-source-source.json | 50 +++
.../camel-azure-storage-queue-sink-sink.json | 2 +-
.../camel-azure-storage-queue-source-source.json | 2 +-
.../connectors/camel-beer-source-source.json | 2 +-
.../connectors/camel-bitcoin-source-source.json | 2 +-
.../connectors/camel-cassandra-sink-sink.json | 10 +-
.../connectors/camel-cassandra-source-source.json | 12 +-
.../resources/connectors/camel-ceph-sink-sink.json | 2 +-
.../connectors/camel-ceph-source-source.json | 2 +-
.../camel-chuck-norris-source-source.json | 2 +-
.../connectors/camel-couchbase-sink-sink.json | 2 +-
.../connectors/camel-cron-source-source.json | 2 +-
.../resources/connectors/camel-cxf-sink.json | 2 +-
.../resources/connectors/camel-cxf-source.json | 7 +-
.../resources/connectors/camel-cxfrs-sink.json | 2 +-
.../resources/connectors/camel-cxfrs-source.json | 7 +-
.../connectors/camel-dropbox-sink-sink.json | 2 +-
.../connectors/camel-dropbox-source-source.json | 2 +-
.../connectors/camel-earthquake-source-source.json | 2 +-
.../camel-elasticsearch-index-sink-sink.json | 12 +-
.../camel-elasticsearch-search-source-source.json | 12 +-
.../resources/connectors/camel-exec-sink-sink.json | 2 +-
.../resources/connectors/camel-fhir-sink-sink.json | 4 +-
.../connectors/camel-fhir-source-source.json | 6 +-
.../resources/connectors/camel-file-sink.json | 16 +-
.../resources/connectors/camel-file-source.json | 28 +-
.../connectors/camel-file-watch-source-source.json | 2 +-
.../resources/connectors/camel-ftp-sink-sink.json | 11 +-
.../connectors/camel-ftp-source-source.json | 16 +-
.../resources/connectors/camel-ftps-sink-sink.json | 11 +-
.../connectors/camel-ftps-source-source.json | 16 +-
.../camel-github-commit-source-source.json | 2 +-
.../camel-github-event-source-source.json | 2 +-
...l-github-pullrequest-comment-source-source.json | 2 +-
.../camel-github-pullrequest-source-source.json | 2 +-
.../connectors/camel-github-tag-source-source.json | 2 +-
.../camel-google-bigquery-sink-sink.json | 2 +-
.../camel-google-calendar-source-source.json | 2 +-
.../camel-google-functions-sink-sink.json | 2 +-
.../camel-google-mail-source-source.json | 2 +-
.../connectors/camel-google-pubsub-sink-sink.json | 2 +-
.../camel-google-pubsub-source-source.json | 2 +-
.../camel-google-sheets-source-source.json | 2 +-
.../camel-google-storage-cdc-source-source.json | 2 +-
.../connectors/camel-google-storage-sink-sink.json | 2 +-
.../camel-google-storage-source-source.json | 2 +-
.../connectors/camel-graphql-sink-sink.json | 25 ++
.../resources/connectors/camel-hdfs-sink.json | 22 +-
.../resources/connectors/camel-hdfs-source.json | 27 +-
.../connectors/camel-http-secured-sink-sink.json | 2 +-
.../camel-http-secured-source-source.json | 2 +-
.../resources/connectors/camel-http-sink-sink.json | 2 +-
.../connectors/camel-http-source-source.json | 2 +-
.../resources/connectors/camel-https-sink.json | 139 ++++----
.../connectors/camel-infinispan-sink-sink.json | 2 +-
.../connectors/camel-infinispan-source-source.json | 4 +-
.../resources/connectors/camel-jdbc-sink.json | 2 +-
.../camel-jira-add-comment-sink-sink.json | 2 +-
.../connectors/camel-jira-add-issue-sink-sink.json | 2 +-
.../connectors/camel-jira-oauth-source-source.json | 2 +-
.../connectors/camel-jira-source-source.json | 2 +-
.../camel-jira-transition-issue-sink-sink.json | 2 +-
.../camel-jira-update-issue-sink-sink.json | 2 +-
.../connectors/camel-jms-amqp-10-sink-sink.json | 2 +-
.../camel-jms-amqp-10-source-source.json | 2 +-
.../camel-jms-apache-activemq-sink-sink.json | 2 +-
.../camel-jms-apache-activemq-source-source.json | 2 +-
.../camel-jms-apache-artemis-sink-sink.json | 2 +-
.../camel-jms-apache-artemis-source-source.json | 2 +-
.../connectors/camel-jms-ibm-mq-sink-sink.json | 8 +-
.../connectors/camel-jms-ibm-mq-source-source.json | 8 +-
.../camel-kafka-not-secured-sink-sink.json | 2 +-
.../camel-kafka-not-secured-source-source.json | 9 +-
.../connectors/camel-kafka-scram-sink-sink.json | 51 +++
.../camel-kafka-scram-source-source.json | 64 ++--
.../connectors/camel-kafka-sink-sink.json | 4 +-
.../connectors/camel-kafka-source-source.json | 6 +-
.../connectors/camel-kafka-ssl-sink-sink.json | 2 +-
.../connectors/camel-kafka-ssl-source-source.json | 4 +-
.../camel-kubernetes-namespaces-source-source.json | 2 +-
.../camel-kubernetes-nodes-source-source.json | 2 +-
.../camel-kubernetes-pods-source-source.json | 2 +-
.../resources/connectors/camel-log-sink-sink.json | 2 +-
.../connectors/camel-mail-imap-source-source.json | 2 +-
.../resources/connectors/camel-mail-sink-sink.json | 2 +-
.../connectors/camel-mariadb-sink-sink.json | 2 +-
.../connectors/camel-mariadb-source-source.json | 2 +-
.../connectors/camel-minio-sink-sink.json | 2 +-
.../connectors/camel-minio-source-source.json | 2 +-
...camel-mongodb-changes-stream-source-source.json | 16 +-
.../connectors/camel-mongodb-sink-sink.json | 18 +-
.../connectors/camel-mongodb-source-source.json | 16 +-
.../resources/connectors/camel-mqtt-sink-sink.json | 2 +-
.../connectors/camel-mqtt-source-source.json | 2 +-
.../connectors/camel-mqtt5-sink-sink.json | 2 +-
.../connectors/camel-mqtt5-source-source.json | 2 +-
.../connectors/camel-mysql-sink-sink.json | 2 +-
.../connectors/camel-mysql-source-source.json | 2 +-
.../resources/connectors/camel-nats-sink-sink.json | 2 +-
.../connectors/camel-nats-source-source.json | 2 +-
.../connectors/camel-netty-http-sink.json | 42 ++-
.../connectors/camel-netty-http-source.json | 19 +-
.../resources/connectors/camel-netty-sink.json | 42 ++-
.../resources/connectors/camel-netty-source.json | 19 +-
.../camel-oracle-database-sink-sink.json | 2 +-
.../camel-oracle-database-source-source.json | 2 +-
.../connectors/camel-postgresql-sink-sink.json | 2 +-
.../connectors/camel-postgresql-source-source.json | 2 +-
.../connectors/camel-pulsar-sink-sink.json | 8 +-
.../connectors/camel-pulsar-source-source.json | 10 +-
.../connectors/camel-rabbitmq-source-source.json | 2 +-
.../connectors/camel-redis-sink-sink.json | 2 +-
.../connectors/camel-redis-source-source.json | 2 +-
.../connectors/camel-rest-openapi-sink-sink.json | 2 +-
.../camel-salesforce-create-sink-sink.json | 2 +-
.../camel-salesforce-delete-sink-sink.json | 2 +-
.../connectors/camel-salesforce-source-source.json | 4 +-
.../camel-salesforce-update-sink-sink.json | 16 +-
.../resources/connectors/camel-scp-sink-sink.json | 2 +-
.../resources/connectors/camel-sftp-sink-sink.json | 11 +-
.../connectors/camel-sftp-source-source.json | 16 +-
.../resources/connectors/camel-sjms2-sink.json | 12 +-
.../resources/connectors/camel-sjms2-source.json | 15 +-
.../connectors/camel-slack-sink-sink.json | 2 +-
.../connectors/camel-slack-source-source.json | 2 +-
.../resources/connectors/camel-solr-sink-sink.json | 2 +-
.../connectors/camel-solr-source-source.json | 2 +-
.../connectors/camel-splunk-hec-sink-sink.json | 2 +-
.../connectors/camel-splunk-sink-sink.json | 2 +-
.../connectors/camel-splunk-source-source.json | 2 +-
.../connectors/camel-sqlserver-sink-sink.json | 2 +-
.../connectors/camel-sqlserver-source-source.json | 2 +-
.../resources/connectors/camel-ssh-sink-sink.json | 2 +-
.../connectors/camel-ssh-source-source.json | 2 +-
.../connectors/camel-telegram-sink-sink.json | 4 +-
.../connectors/camel-telegram-source-source.json | 4 +-
.../connectors/camel-timer-source-source.json | 2 +-
.../camel-twitter-directmessage-source-source.json | 2 +-
.../camel-twitter-search-source-source.json | 2 +-
.../camel-twitter-timeline-source-source.json | 2 +-
.../connectors/camel-webhook-source-source.json | 2 +-
.../connectors/camel-websocket-source-source.json | 2 +-
.../connectors/camel-wttrin-source-source.json | 2 +-
.../resources/descriptors/connectors.properties | 12 +-
.../pom.xml | 2 +-
.../camel-aws-cloudtrail-source-source.json | 2 +-
.../CamelAwscloudtrailsourceSourceConnector.java | 3 +-
...elAwscloudtrailsourceSourceConnectorConfig.java | 3 +-
.../CamelAwscloudtrailsourceSourceTask.java | 3 +-
.../kamelets/aws-cloudtrail-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-aws-cloudwatch-sink-sink.json | 2 +-
.../CamelAwscloudwatchsinkSinkConnector.java | 3 +-
.../CamelAwscloudwatchsinkSinkConnectorConfig.java | 3 +-
.../CamelAwscloudwatchsinkSinkTask.java | 3 +-
.../kamelets/aws-cloudwatch-sink.kamelet.yaml | 3 +-
.../pom.xml | 156 ---------
.../descriptors/connector-sink.properties | 1 -
.../camel-aws-ddb-experimental-sink-sink.json | 78 -----
.../CamelAwsddbexperimentalsinkSinkConnector.java | 37 --
...lAwsddbexperimentalsinkSinkConnectorConfig.java | 85 -----
.../CamelAwsddbexperimentalsinkSinkTask.java | 37 --
.../aws-ddb-experimental-sink.kamelet.yaml | 148 --------
.../camel-aws-ddb-sink-kafka-connector/pom.xml | 4 +-
.../resources/camel-aws-ddb-sink-sink.json | 13 +-
.../awsddbsink/CamelAwsddbsinkSinkConnector.java | 3 +-
.../CamelAwsddbsinkSinkConnectorConfig.java | 9 +-
.../awsddbsink/CamelAwsddbsinkSinkTask.java | 3 +-
.../resources/kamelets/aws-ddb-sink.kamelet.yaml | 40 ++-
.../pom.xml | 2 +-
.../camel-aws-ddb-streams-source-source.json | 2 +-
.../CamelAwsddbstreamssourceSourceConnector.java | 3 +-
...elAwsddbstreamssourceSourceConnectorConfig.java | 3 +-
.../CamelAwsddbstreamssourceSourceTask.java | 3 +-
.../kamelets/aws-ddb-streams-source.kamelet.yaml | 3 +-
.../camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-aws-ec2-sink-sink.json | 2 +-
.../awsec2sink/CamelAwsec2sinkSinkConnector.java | 3 +-
.../CamelAwsec2sinkSinkConnectorConfig.java | 3 +-
.../awsec2sink/CamelAwsec2sinkSinkTask.java | 3 +-
.../resources/kamelets/aws-ec2-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-aws-eventbridge-sink-sink.json | 2 +-
.../CamelAwseventbridgesinkSinkConnector.java | 3 +-
...CamelAwseventbridgesinkSinkConnectorConfig.java | 3 +-
.../CamelAwseventbridgesinkSinkTask.java | 3 +-
.../kamelets/aws-eventbridge-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-aws-kinesis-firehose-sink-sink.json | 2 +-
.../CamelAwskinesisfirehosesinkSinkConnector.java | 3 +-
...lAwskinesisfirehosesinkSinkConnectorConfig.java | 3 +-
.../CamelAwskinesisfirehosesinkSinkTask.java | 3 +-
.../aws-kinesis-firehose-sink.kamelet.yaml | 3 +-
.../camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-aws-kinesis-sink-sink.json | 2 +-
.../CamelAwskinesissinkSinkConnector.java | 3 +-
.../CamelAwskinesissinkSinkConnectorConfig.java | 3 +-
.../CamelAwskinesissinkSinkTask.java | 3 +-
.../kamelets/aws-kinesis-sink.kamelet.yaml | 3 +-
.../pom.xml | 4 +-
.../resources/camel-aws-kinesis-source-source.json | 2 +-
.../CamelAwskinesissourceSourceConnector.java | 3 +-
...CamelAwskinesissourceSourceConnectorConfig.java | 3 +-
.../CamelAwskinesissourceSourceTask.java | 3 +-
.../kamelets/aws-kinesis-source.kamelet.yaml | 19 +-
.../camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-aws-lambda-sink-sink.json | 2 +-
.../CamelAwslambdasinkSinkConnector.java | 3 +-
.../CamelAwslambdasinkSinkConnectorConfig.java | 3 +-
.../awslambdasink/CamelAwslambdasinkSinkTask.java | 3 +-
.../kamelets/aws-lambda-sink.kamelet.yaml | 3 +-
.../pom.xml | 12 +-
.../resources/camel-aws-redshift-sink-sink.json | 2 +-
.../CamelAwsredshiftsinkSinkConnector.java | 3 +-
.../CamelAwsredshiftsinkSinkConnectorConfig.java | 3 +-
.../CamelAwsredshiftsinkSinkTask.java | 3 +-
.../kamelets/aws-redshift-sink.kamelet.yaml | 19 +-
.../pom.xml | 12 +-
.../camel-aws-redshift-source-source.json | 2 +-
.../CamelAwsredshiftsourceSourceConnector.java | 3 +-
...amelAwsredshiftsourceSourceConnectorConfig.java | 3 +-
.../CamelAwsredshiftsourceSourceTask.java | 3 +-
.../kamelets/aws-redshift-source.kamelet.yaml | 19 +-
.../pom.xml | 2 +-
.../resources/camel-aws-s3-cdc-source-source.json | 2 +-
.../CamelAwss3cdcsourceSourceConnector.java | 3 +-
.../CamelAwss3cdcsourceSourceConnectorConfig.java | 3 +-
.../CamelAwss3cdcsourceSourceTask.java | 3 +-
.../kamelets/aws-s3-cdc-source.kamelet.yaml | 3 +-
.../pom.xml | 152 --------
.../descriptors/connector-source.properties | 1 -
.../camel-aws-s3-experimental-source-source.json | 105 ------
...ss3experimentalsourceSourceConnector.properties | 34 --
...amelAwss3experimentalsourceSourceConnector.java | 37 --
...ss3experimentalsourceSourceConnectorConfig.java | 101 ------
.../CamelAwss3experimentalsourceSourceTask.java | 37 --
.../aws-s3-experimental-source.kamelet.yaml | 167 ---------
.../camel-aws-s3-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-aws-s3-sink-sink.json | 2 +-
.../awss3sink/CamelAwss3sinkSinkConnector.java | 3 +-
.../CamelAwss3sinkSinkConnectorConfig.java | 3 +-
.../awss3sink/CamelAwss3sinkSinkTask.java | 3 +-
.../resources/kamelets/aws-s3-sink.kamelet.yaml | 3 +-
.../camel-aws-s3-source-kafka-connector/pom.xml | 4 +-
.../resources/camel-aws-s3-source-source.json | 9 +-
.../CamelAwss3sourceSourceConnector.java | 3 +-
.../CamelAwss3sourceSourceConnectorConfig.java | 7 +-
.../awss3source/CamelAwss3sourceSourceTask.java | 3 +-
.../resources/kamelets/aws-s3-source.kamelet.yaml | 27 +-
.../pom.xml | 2 +-
.../camel-aws-s3-streaming-upload-sink-sink.json | 2 +-
...CamelAwss3streaminguploadsinkSinkConnector.java | 3 +-
...wss3streaminguploadsinkSinkConnectorConfig.java | 3 +-
.../CamelAwss3streaminguploadsinkSinkTask.java | 3 +-
.../aws-s3-streaming-upload-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-aws-secrets-manager-sink-sink.json | 2 +-
.../CamelAwssecretsmanagersinkSinkConnector.java | 3 +-
...elAwssecretsmanagersinkSinkConnectorConfig.java | 3 +-
.../CamelAwssecretsmanagersinkSinkTask.java | 3 +-
.../kamelets/aws-secrets-manager-sink.kamelet.yaml | 3 +-
.../camel-aws-ses-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-aws-ses-sink-sink.json | 2 +-
.../awssessink/CamelAwssessinkSinkConnector.java | 3 +-
.../CamelAwssessinkSinkConnectorConfig.java | 3 +-
.../awssessink/CamelAwssessinkSinkTask.java | 3 +-
.../resources/kamelets/aws-ses-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-aws-sns-fifo-sink-sink.json | 2 +-
.../CamelAwssnsfifosinkSinkConnector.java | 3 +-
.../CamelAwssnsfifosinkSinkConnectorConfig.java | 3 +-
.../CamelAwssnsfifosinkSinkTask.java | 3 +-
.../kamelets/aws-sns-fifo-sink.kamelet.yaml | 3 +-
.../camel-aws-sns-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-aws-sns-sink-sink.json | 2 +-
.../awssnssink/CamelAwssnssinkSinkConnector.java | 3 +-
.../CamelAwssnssinkSinkConnectorConfig.java | 3 +-
.../awssnssink/CamelAwssnssinkSinkTask.java | 3 +-
.../resources/kamelets/aws-sns-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-aws-sqs-batch-sink-sink.json | 2 +-
.../CamelAwssqsbatchsinkSinkConnector.java | 3 +-
.../CamelAwssqsbatchsinkSinkConnectorConfig.java | 3 +-
.../CamelAwssqsbatchsinkSinkTask.java | 3 +-
.../kamelets/aws-sqs-batch-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-aws-sqs-fifo-sink-sink.json | 2 +-
.../CamelAwssqsfifosinkSinkConnector.java | 3 +-
.../CamelAwssqsfifosinkSinkConnectorConfig.java | 3 +-
.../CamelAwssqsfifosinkSinkTask.java | 3 +-
.../kamelets/aws-sqs-fifo-sink.kamelet.yaml | 3 +-
.../camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-aws-sqs-sink-sink.json | 2 +-
.../awssqssink/CamelAwssqssinkSinkConnector.java | 3 +-
.../CamelAwssqssinkSinkConnectorConfig.java | 3 +-
.../awssqssink/CamelAwssqssinkSinkTask.java | 3 +-
.../resources/kamelets/aws-sqs-sink.kamelet.yaml | 3 +-
.../camel-aws-sqs-source-kafka-connector/pom.xml | 4 +-
.../resources/camel-aws-sqs-source-source.json | 2 +-
.../CamelAwssqssourceSourceConnector.java | 3 +-
.../CamelAwssqssourceSourceConnectorConfig.java | 3 +-
.../awssqssource/CamelAwssqssourceSourceTask.java | 3 +-
.../resources/kamelets/aws-sqs-source.kamelet.yaml | 19 +-
connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-aws2-iam-sink.json | 144 +++++---
.../aws2iam/CamelAws2iamSinkConnector.java | 3 +-
.../aws2iam/CamelAws2iamSinkConnectorConfig.java | 107 +++---
.../aws2iam/CamelAws2iamSinkTask.java | 3 +-
connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-aws2-kms-sink.json | 150 ++++----
.../aws2kms/CamelAws2kmsSinkConnector.java | 3 +-
.../aws2kms/CamelAws2kmsSinkConnectorConfig.java | 115 +++---
.../aws2kms/CamelAws2kmsSinkTask.java | 3 +-
.../pom.xml | 16 +-
.../descriptors/connector-sink.properties | 1 +
.../resources/camel-azure-cosmosdb-sink-sink.json | 43 +++
.../src/main/assembly/package.xml | 0
...CamelAzurecosmosdbsinkSinkConnector.properties} | 16 +-
.../CamelAzurecosmosdbsinkSinkConnector.java} | 9 +-
.../CamelAzurecosmosdbsinkSinkConnectorConfig.java | 64 ++++
.../CamelAzurecosmosdbsinkSinkTask.java} | 9 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../kamelets/azure-cosmosdb-sink.kamelet.yaml} | 83 ++---
.../pom.xml | 2 +-
.../camel-azure-cosmosdb-source-source.json | 2 +-
.../CamelAzurecosmosdbsourceSourceConnector.java | 3 +-
...elAzurecosmosdbsourceSourceConnectorConfig.java | 3 +-
.../CamelAzurecosmosdbsourceSourceTask.java | 3 +-
.../kamelets/azure-cosmosdb-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-azure-eventhubs-sink-sink.json | 2 +-
.../CamelAzureeventhubssinkSinkConnector.java | 3 +-
...CamelAzureeventhubssinkSinkConnectorConfig.java | 3 +-
.../CamelAzureeventhubssinkSinkTask.java | 3 +-
.../kamelets/azure-eventhubs-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-azure-eventhubs-source-source.json | 2 +-
.../CamelAzureeventhubssourceSourceConnector.java | 3 +-
...lAzureeventhubssourceSourceConnectorConfig.java | 3 +-
.../CamelAzureeventhubssourceSourceTask.java | 3 +-
.../kamelets/azure-eventhubs-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-azure-functions-sink-sink.json | 2 +-
.../CamelAzurefunctionssinkSinkConnector.java | 3 +-
...CamelAzurefunctionssinkSinkConnectorConfig.java | 3 +-
.../CamelAzurefunctionssinkSinkTask.java | 3 +-
.../kamelets/azure-functions-sink.kamelet.yaml | 4 +-
.../pom.xml | 2 +-
.../camel-azure-servicebus-sink-sink.json | 2 +-
.../CamelAzureservicebussinkSinkConnector.java | 3 +-
...amelAzureservicebussinkSinkConnectorConfig.java | 3 +-
.../CamelAzureservicebussinkSinkTask.java | 3 +-
.../kamelets/azure-servicebus-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-azure-servicebus-source-source.json | 4 +-
.../CamelAzureservicebussourceSourceConnector.java | 3 +-
...AzureservicebussourceSourceConnectorConfig.java | 5 +-
.../CamelAzureservicebussourceSourceTask.java | 3 +-
.../kamelets/azure-servicebus-source.kamelet.yaml | 6 +-
.../pom.xml | 2 +-
...camel-azure-storage-blob-cdc-source-source.json | 6 +-
...elAzurestorageblobcdcsourceSourceConnector.java | 3 +-
...estorageblobcdcsourceSourceConnectorConfig.java | 7 +-
.../CamelAzurestorageblobcdcsourceSourceTask.java | 3 +-
.../azure-storage-blob-cdc-source.kamelet.yaml | 9 +-
.../pom.xml | 2 +-
...zure-storage-blob-changefeed-source-source.json | 9 +-
...storageblobchangefeedsourceSourceConnector.java | 3 +-
...eblobchangefeedsourceSourceConnectorConfig.java | 7 +-
...AzurestorageblobchangefeedsourceSourceTask.java | 3 +-
...ure-storage-blob-changefeed-source.kamelet.yaml | 10 +-
.../pom.xml | 2 +-
.../camel-azure-storage-blob-sink-sink.json | 11 +-
...melAzurestorageblobsinkSinkConnector.properties | 2 -
.../CamelAzurestorageblobsinkSinkConnector.java | 3 +-
...melAzurestorageblobsinkSinkConnectorConfig.java | 11 +-
.../CamelAzurestorageblobsinkSinkTask.java | 3 +-
.../kamelets/azure-storage-blob-sink.kamelet.yaml | 18 +-
.../pom.xml | 4 +-
.../camel-azure-storage-blob-source-source.json | 16 +-
...zurestorageblobsourceSourceConnector.properties | 2 -
...CamelAzurestorageblobsourceSourceConnector.java | 3 +-
...zurestorageblobsourceSourceConnectorConfig.java | 13 +-
.../CamelAzurestorageblobsourceSourceTask.java | 3 +-
.../azure-storage-blob-source.kamelet.yaml | 35 +-
.../pom.xml | 2 +-
.../camel-azure-storage-queue-sink-sink.json | 2 +-
.../CamelAzurestoragequeuesinkSinkConnector.java | 3 +-
...elAzurestoragequeuesinkSinkConnectorConfig.java | 3 +-
.../CamelAzurestoragequeuesinkSinkTask.java | 3 +-
.../kamelets/azure-storage-queue-sink.kamelet.yaml | 3 +-
.../pom.xml | 4 +-
.../camel-azure-storage-queue-source-source.json | 2 +-
...amelAzurestoragequeuesourceSourceConnector.java | 3 +-
...urestoragequeuesourceSourceConnectorConfig.java | 3 +-
.../CamelAzurestoragequeuesourceSourceTask.java | 3 +-
.../azure-storage-queue-source.kamelet.yaml | 19 +-
.../camel-beer-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-beer-source-source.json | 2 +-
.../beersource/CamelBeersourceSourceConnector.java | 3 +-
.../CamelBeersourceSourceConnectorConfig.java | 3 +-
.../beersource/CamelBeersourceSourceTask.java | 3 +-
.../resources/kamelets/beer-source.kamelet.yaml | 3 +-
.../camel-bitcoin-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-bitcoin-source-source.json | 2 +-
.../CamelBitcoinsourceSourceConnector.java | 3 +-
.../CamelBitcoinsourceSourceConnectorConfig.java | 3 +-
.../CamelBitcoinsourceSourceTask.java | 3 +-
.../resources/kamelets/bitcoin-source.kamelet.yaml | 3 +-
.../camel-cassandra-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-cassandra-sink-sink.json | 10 +-
.../CamelCassandrasinkSinkConnector.java | 3 +-
.../CamelCassandrasinkSinkConnectorConfig.java | 9 +-
.../cassandrasink/CamelCassandrasinkSinkTask.java | 3 +-
.../resources/kamelets/cassandra-sink.kamelet.yaml | 14 +-
.../camel-cassandra-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-cassandra-source-source.json | 12 +-
.../CamelCassandrasourceSourceConnector.java | 3 +-
.../CamelCassandrasourceSourceConnectorConfig.java | 11 +-
.../CamelCassandrasourceSourceTask.java | 3 +-
.../kamelets/cassandra-source.kamelet.yaml | 15 +-
connectors/camel-ceph-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-ceph-sink-sink.json | 2 +-
.../cephsink/CamelCephsinkSinkConnector.java | 3 +-
.../cephsink/CamelCephsinkSinkConnectorConfig.java | 3 +-
.../cephsink/CamelCephsinkSinkTask.java | 3 +-
.../main/resources/kamelets/ceph-sink.kamelet.yaml | 3 +-
.../camel-ceph-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-ceph-source-source.json | 2 +-
.../cephsource/CamelCephsourceSourceConnector.java | 3 +-
.../CamelCephsourceSourceConnectorConfig.java | 3 +-
.../cephsource/CamelCephsourceSourceTask.java | 3 +-
.../resources/kamelets/ceph-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-chuck-norris-source-source.json | 2 +-
.../CamelChucknorrissourceSourceConnector.java | 3 +-
...amelChucknorrissourceSourceConnectorConfig.java | 3 +-
.../CamelChucknorrissourceSourceTask.java | 3 +-
.../kamelets/chuck-norris-source.kamelet.yaml | 3 +-
.../camel-couchbase-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-couchbase-sink-sink.json | 2 +-
.../CamelCouchbasesinkSinkConnector.java | 3 +-
.../CamelCouchbasesinkSinkConnectorConfig.java | 3 +-
.../couchbasesink/CamelCouchbasesinkSinkTask.java | 3 +-
.../resources/kamelets/couchbase-sink.kamelet.yaml | 3 +-
.../camel-cron-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-cron-source-source.json | 2 +-
.../cronsource/CamelCronsourceSourceConnector.java | 3 +-
.../CamelCronsourceSourceConnectorConfig.java | 3 +-
.../cronsource/CamelCronsourceSourceTask.java | 3 +-
.../resources/kamelets/cron-source.kamelet.yaml | 3 +-
connectors/camel-cxf-kafka-connector/pom.xml | 2 +-
.../src/generated/resources/camel-cxf-sink.json | 2 +-
.../src/generated/resources/camel-cxf-source.json | 7 +-
.../kafkaconnector/cxf/CamelCxfSinkConnector.java | 3 +-
.../cxf/CamelCxfSinkConnectorConfig.java | 3 +-
.../camel/kafkaconnector/cxf/CamelCxfSinkTask.java | 3 +-
.../cxf/CamelCxfSourceConnector.java | 3 +-
.../cxf/CamelCxfSourceConnectorConfig.java | 5 +-
.../kafkaconnector/cxf/CamelCxfSourceTask.java | 3 +-
connectors/camel-cxfrs-kafka-connector/pom.xml | 2 +-
.../src/generated/resources/camel-cxfrs-sink.json | 2 +-
.../generated/resources/camel-cxfrs-source.json | 7 +-
.../cxfrs/CamelCxfrsSinkConnector.java | 3 +-
.../cxfrs/CamelCxfrsSinkConnectorConfig.java | 3 +-
.../kafkaconnector/cxfrs/CamelCxfrsSinkTask.java | 3 +-
.../cxfrs/CamelCxfrsSourceConnector.java | 3 +-
.../cxfrs/CamelCxfrsSourceConnectorConfig.java | 5 +-
.../kafkaconnector/cxfrs/CamelCxfrsSourceTask.java | 3 +-
.../camel-dropbox-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-dropbox-sink-sink.json | 2 +-
.../dropboxsink/CamelDropboxsinkSinkConnector.java | 3 +-
.../CamelDropboxsinkSinkConnectorConfig.java | 3 +-
.../dropboxsink/CamelDropboxsinkSinkTask.java | 3 +-
.../resources/kamelets/dropbox-sink.kamelet.yaml | 3 +-
.../camel-dropbox-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-dropbox-source-source.json | 2 +-
.../CamelDropboxsourceSourceConnector.java | 3 +-
.../CamelDropboxsourceSourceConnectorConfig.java | 3 +-
.../CamelDropboxsourceSourceTask.java | 3 +-
.../resources/kamelets/dropbox-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-earthquake-source-source.json | 2 +-
.../CamelEarthquakesourceSourceConnector.java | 3 +-
...CamelEarthquakesourceSourceConnectorConfig.java | 3 +-
.../CamelEarthquakesourceSourceTask.java | 3 +-
.../kamelets/earthquake-source.kamelet.yaml | 3 +-
.../pom.xml | 8 +-
.../camel-elasticsearch-index-sink-sink.json | 12 +-
.../CamelElasticsearchindexsinkSinkConnector.java | 3 +-
...lElasticsearchindexsinkSinkConnectorConfig.java | 7 +-
.../CamelElasticsearchindexsinkSinkTask.java | 3 +-
.../kamelets/elasticsearch-index-sink.kamelet.yaml | 20 +-
.../pom.xml | 6 +-
.../camel-elasticsearch-search-source-source.json | 12 +-
...elElasticsearchsearchsourceSourceConnector.java | 3 +-
...ticsearchsearchsourceSourceConnectorConfig.java | 7 +-
.../CamelElasticsearchsearchsourceSourceTask.java | 3 +-
.../elasticsearch-search-source.kamelet.yaml | 21 +-
connectors/camel-exec-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-exec-sink-sink.json | 2 +-
.../execsink/CamelExecsinkSinkConnector.java | 3 +-
.../execsink/CamelExecsinkSinkConnectorConfig.java | 3 +-
.../execsink/CamelExecsinkSinkTask.java | 3 +-
.../main/resources/kamelets/exec-sink.kamelet.yaml | 3 +-
connectors/camel-fhir-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-fhir-sink-sink.json | 4 +-
.../fhirsink/CamelFhirsinkSinkConnector.java | 3 +-
.../fhirsink/CamelFhirsinkSinkConnectorConfig.java | 3 +-
.../fhirsink/CamelFhirsinkSinkTask.java | 3 +-
.../main/resources/kamelets/fhir-sink.kamelet.yaml | 3 +-
.../camel-fhir-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-fhir-source-source.json | 6 +-
.../fhirsource/CamelFhirsourceSourceConnector.java | 3 +-
.../CamelFhirsourceSourceConnectorConfig.java | 7 +-
.../fhirsource/CamelFhirsourceSourceTask.java | 3 +-
.../resources/kamelets/fhir-source.kamelet.yaml | 9 +-
connectors/camel-file-kafka-connector/pom.xml | 2 +-
.../src/generated/resources/camel-file-sink.json | 16 +-
.../src/generated/resources/camel-file-source.json | 28 +-
.../file/CamelFileSinkConnector.java | 3 +-
.../file/CamelFileSinkConnectorConfig.java | 11 +-
.../kafkaconnector/file/CamelFileSinkTask.java | 3 +-
.../file/CamelFileSourceConnector.java | 3 +-
.../file/CamelFileSourceConnectorConfig.java | 17 +-
.../kafkaconnector/file/CamelFileSourceTask.java | 3 +-
.../pom.xml | 2 +-
.../resources/camel-file-watch-source-source.json | 2 +-
.../CamelFilewatchsourceSourceConnector.java | 3 +-
.../CamelFilewatchsourceSourceConnectorConfig.java | 3 +-
.../CamelFilewatchsourceSourceTask.java | 3 +-
.../kamelets/file-watch-source.kamelet.yaml | 3 +-
connectors/camel-ftp-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-ftp-sink-sink.json | 11 +-
.../ftpsink/CamelFtpsinkSinkConnector.java | 3 +-
.../ftpsink/CamelFtpsinkSinkConnectorConfig.java | 9 +-
.../ftpsink/CamelFtpsinkSinkTask.java | 3 +-
.../main/resources/kamelets/ftp-sink.kamelet.yaml | 16 +-
.../camel-ftp-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-ftp-source-source.json | 16 +-
.../ftpsource/CamelFtpsourceSourceConnector.java | 3 +-
.../CamelFtpsourceSourceConnectorConfig.java | 11 +-
.../ftpsource/CamelFtpsourceSourceTask.java | 3 +-
.../resources/kamelets/ftp-source.kamelet.yaml | 19 +-
connectors/camel-ftps-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-ftps-sink-sink.json | 11 +-
.../ftpssink/CamelFtpssinkSinkConnector.java | 3 +-
.../ftpssink/CamelFtpssinkSinkConnectorConfig.java | 9 +-
.../ftpssink/CamelFtpssinkSinkTask.java | 3 +-
.../main/resources/kamelets/ftps-sink.kamelet.yaml | 16 +-
.../camel-ftps-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-ftps-source-source.json | 16 +-
.../ftpssource/CamelFtpssourceSourceConnector.java | 3 +-
.../CamelFtpssourceSourceConnectorConfig.java | 11 +-
.../ftpssource/CamelFtpssourceSourceTask.java | 3 +-
.../resources/kamelets/ftps-source.kamelet.yaml | 19 +-
.../pom.xml | 2 +-
.../camel-github-commit-source-source.json | 2 +-
.../CamelGithubcommitsourceSourceConnector.java | 3 +-
...melGithubcommitsourceSourceConnectorConfig.java | 3 +-
.../CamelGithubcommitsourceSourceTask.java | 3 +-
.../kamelets/github-commit-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-github-event-source-source.json | 2 +-
.../CamelGithubeventsourceSourceConnector.java | 3 +-
...amelGithubeventsourceSourceConnectorConfig.java | 3 +-
.../CamelGithubeventsourceSourceTask.java | 3 +-
.../kamelets/github-event-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
...l-github-pullrequest-comment-source-source.json | 2 +-
...hubpullrequestcommentsourceSourceConnector.java | 3 +-
...lrequestcommentsourceSourceConnectorConfig.java | 3 +-
...elGithubpullrequestcommentsourceSourceTask.java | 3 +-
.../github-pullrequest-comment-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-github-pullrequest-source-source.json | 2 +-
...amelGithubpullrequestsourceSourceConnector.java | 3 +-
...thubpullrequestsourceSourceConnectorConfig.java | 3 +-
.../CamelGithubpullrequestsourceSourceTask.java | 3 +-
.../github-pullrequest-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-github-tag-source-source.json | 2 +-
.../CamelGithubtagsourceSourceConnector.java | 3 +-
.../CamelGithubtagsourceSourceConnectorConfig.java | 3 +-
.../CamelGithubtagsourceSourceTask.java | 3 +-
.../kamelets/github-tag-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-google-bigquery-sink-sink.json | 2 +-
.../CamelGooglebigquerysinkSinkConnector.java | 3 +-
...CamelGooglebigquerysinkSinkConnectorConfig.java | 3 +-
.../CamelGooglebigquerysinkSinkTask.java | 3 +-
.../kamelets/google-bigquery-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-google-calendar-source-source.json | 2 +-
.../CamelGooglecalendarsourceSourceConnector.java | 3 +-
...lGooglecalendarsourceSourceConnectorConfig.java | 3 +-
.../CamelGooglecalendarsourceSourceTask.java | 3 +-
.../kamelets/google-calendar-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-google-functions-sink-sink.json | 2 +-
.../CamelGooglefunctionssinkSinkConnector.java | 3 +-
...amelGooglefunctionssinkSinkConnectorConfig.java | 3 +-
.../CamelGooglefunctionssinkSinkTask.java | 3 +-
.../kamelets/google-functions-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-google-mail-source-source.json | 2 +-
.../CamelGooglemailsourceSourceConnector.java | 3 +-
...CamelGooglemailsourceSourceConnectorConfig.java | 3 +-
.../CamelGooglemailsourceSourceTask.java | 3 +-
.../kamelets/google-mail-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-google-pubsub-sink-sink.json | 2 +-
.../CamelGooglepubsubsinkSinkConnector.java | 3 +-
.../CamelGooglepubsubsinkSinkConnectorConfig.java | 3 +-
.../CamelGooglepubsubsinkSinkTask.java | 3 +-
.../kamelets/google-pubsub-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-google-pubsub-source-source.json | 2 +-
.../CamelGooglepubsubsourceSourceConnector.java | 3 +-
...melGooglepubsubsourceSourceConnectorConfig.java | 3 +-
.../CamelGooglepubsubsourceSourceTask.java | 3 +-
.../kamelets/google-pubsub-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-google-sheets-source-source.json | 2 +-
.../CamelGooglesheetssourceSourceConnector.java | 3 +-
...melGooglesheetssourceSourceConnectorConfig.java | 3 +-
.../CamelGooglesheetssourceSourceTask.java | 3 +-
.../kamelets/google-sheets-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-google-storage-cdc-source-source.json | 2 +-
...CamelGooglestoragecdcsourceSourceConnector.java | 3 +-
...ooglestoragecdcsourceSourceConnectorConfig.java | 3 +-
.../CamelGooglestoragecdcsourceSourceTask.java | 3 +-
.../google-storage-cdc-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-google-storage-sink-sink.json | 2 +-
.../CamelGooglestoragesinkSinkConnector.java | 3 +-
.../CamelGooglestoragesinkSinkConnectorConfig.java | 3 +-
.../CamelGooglestoragesinkSinkTask.java | 3 +-
.../kamelets/google-storage-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-google-storage-source-source.json | 2 +-
.../CamelGooglestoragesourceSourceConnector.java | 3 +-
...elGooglestoragesourceSourceConnectorConfig.java | 3 +-
.../CamelGooglestoragesourceSourceTask.java | 3 +-
.../kamelets/google-storage-source.kamelet.yaml | 3 +-
.../pom.xml | 16 +-
.../descriptors/connector-sink.properties | 1 +
.../resources/camel-graphql-sink-sink.json | 25 ++
.../src/main/assembly/package.xml | 0
.../CamelGraphqlsinkSinkConnector.properties} | 8 +-
.../CamelGraphqlsinkSinkConnector.java} | 9 +-
.../CamelGraphqlsinkSinkConnectorConfig.java} | 21 +-
.../graphqlsink/CamelGraphqlsinkSinkTask.java} | 9 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../resources/kamelets/graphql-sink.kamelet.yaml} | 38 +-
connectors/camel-hdfs-kafka-connector/pom.xml | 2 +-
.../src/generated/resources/camel-hdfs-sink.json | 22 +-
.../src/generated/resources/camel-hdfs-source.json | 27 +-
.../hdfs/CamelHdfsSinkConnector.java | 3 +-
.../hdfs/CamelHdfsSinkConnectorConfig.java | 15 +-
.../kafkaconnector/hdfs/CamelHdfsSinkTask.java | 3 +-
.../hdfs/CamelHdfsSourceConnector.java | 3 +-
.../hdfs/CamelHdfsSourceConnectorConfig.java | 17 +-
.../kafkaconnector/hdfs/CamelHdfsSourceTask.java | 3 +-
.../pom.xml | 2 +-
.../resources/camel-http-secured-sink-sink.json | 2 +-
.../CamelHttpsecuredsinkSinkConnector.java | 3 +-
.../CamelHttpsecuredsinkSinkConnectorConfig.java | 3 +-
.../CamelHttpsecuredsinkSinkTask.java | 3 +-
.../kamelets/http-secured-sink.kamelet.yaml | 4 +-
.../pom.xml | 2 +-
.../camel-http-secured-source-source.json | 2 +-
.../CamelHttpsecuredsourceSourceConnector.java | 3 +-
...amelHttpsecuredsourceSourceConnectorConfig.java | 3 +-
.../CamelHttpsecuredsourceSourceTask.java | 3 +-
.../kamelets/http-secured-source.kamelet.yaml | 3 +-
connectors/camel-http-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-http-sink-sink.json | 2 +-
.../httpsink/CamelHttpsinkSinkConnector.java | 3 +-
.../httpsink/CamelHttpsinkSinkConnectorConfig.java | 3 +-
.../httpsink/CamelHttpsinkSinkTask.java | 3 +-
.../main/resources/kamelets/http-sink.kamelet.yaml | 4 +-
.../camel-http-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-http-source-source.json | 2 +-
.../httpsource/CamelHttpsourceSourceConnector.java | 3 +-
.../CamelHttpsourceSourceConnectorConfig.java | 3 +-
.../httpsource/CamelHttpsourceSourceTask.java | 3 +-
.../resources/kamelets/http-source.kamelet.yaml | 3 +-
connectors/camel-https-kafka-connector/pom.xml | 2 +-
.../src/generated/resources/camel-https-sink.json | 139 ++++----
.../https/CamelHttpsSinkConnector.java | 3 +-
.../https/CamelHttpsSinkConnectorConfig.java | 99 +++---
.../kafkaconnector/https/CamelHttpsSinkTask.java | 3 +-
.../camel-infinispan-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-infinispan-sink-sink.json | 2 +-
.../CamelInfinispansinkSinkConnector.java | 3 +-
.../CamelInfinispansinkSinkConnectorConfig.java | 3 +-
.../CamelInfinispansinkSinkTask.java | 3 +-
.../kamelets/infinispan-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-infinispan-source-source.json | 4 +-
.../CamelInfinispansourceSourceConnector.java | 3 +-
...CamelInfinispansourceSourceConnectorConfig.java | 5 +-
.../CamelInfinispansourceSourceTask.java | 3 +-
.../kamelets/infinispan-source.kamelet.yaml | 6 +-
connectors/camel-jdbc-kafka-connector/pom.xml | 2 +-
.../src/generated/resources/camel-jdbc-sink.json | 2 +-
.../jdbc/CamelJdbcSinkConnector.java | 3 +-
.../jdbc/CamelJdbcSinkConnectorConfig.java | 3 +-
.../kafkaconnector/jdbc/CamelJdbcSinkTask.java | 3 +-
.../pom.xml | 2 +-
.../camel-jira-add-comment-sink-sink.json | 2 +-
.../CamelJiraaddcommentsinkSinkConnector.java | 3 +-
...CamelJiraaddcommentsinkSinkConnectorConfig.java | 3 +-
.../CamelJiraaddcommentsinkSinkTask.java | 3 +-
.../kamelets/jira-add-comment-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-jira-add-issue-sink-sink.json | 2 +-
.../CamelJiraaddissuesinkSinkConnector.java | 3 +-
.../CamelJiraaddissuesinkSinkConnectorConfig.java | 3 +-
.../CamelJiraaddissuesinkSinkTask.java | 3 +-
.../kamelets/jira-add-issue-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-jira-oauth-source-source.json | 2 +-
.../CamelJiraoauthsourceSourceConnector.java | 3 +-
.../CamelJiraoauthsourceSourceConnectorConfig.java | 3 +-
.../CamelJiraoauthsourceSourceTask.java | 3 +-
.../kamelets/jira-oauth-source.kamelet.yaml | 3 +-
.../camel-jira-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-jira-source-source.json | 2 +-
.../jirasource/CamelJirasourceSourceConnector.java | 3 +-
.../CamelJirasourceSourceConnectorConfig.java | 3 +-
.../jirasource/CamelJirasourceSourceTask.java | 3 +-
.../resources/kamelets/jira-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-jira-transition-issue-sink-sink.json | 2 +-
.../CamelJiratransitionissuesinkSinkConnector.java | 3 +-
...JiratransitionissuesinkSinkConnectorConfig.java | 3 +-
.../CamelJiratransitionissuesinkSinkTask.java | 3 +-
.../jira-transition-issue-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-jira-update-issue-sink-sink.json | 2 +-
.../CamelJiraupdateissuesinkSinkConnector.java | 3 +-
...amelJiraupdateissuesinkSinkConnectorConfig.java | 3 +-
.../CamelJiraupdateissuesinkSinkTask.java | 3 +-
.../kamelets/jira-update-issue-sink.kamelet.yaml | 3 +-
.../camel-jms-amqp-10-sink-kafka-connector/pom.xml | 7 +-
.../resources/camel-jms-amqp-10-sink-sink.json | 2 +-
.../CamelJmsamqp10sinkSinkConnector.java | 3 +-
.../CamelJmsamqp10sinkSinkConnectorConfig.java | 3 +-
.../jmsamqp10sink/CamelJmsamqp10sinkSinkTask.java | 3 +-
.../kamelets/jms-amqp-10-sink.kamelet.yaml | 10 +-
.../pom.xml | 7 +-
.../resources/camel-jms-amqp-10-source-source.json | 2 +-
.../CamelJmsamqp10sourceSourceConnector.java | 3 +-
.../CamelJmsamqp10sourceSourceConnectorConfig.java | 3 +-
.../CamelJmsamqp10sourceSourceTask.java | 3 +-
.../kamelets/jms-amqp-10-source.kamelet.yaml | 10 +-
.../pom.xml | 148 --------
.../descriptors/connector-sink.properties | 1 -
.../camel-jms-apache-activemq-sink-sink.json | 46 ---
...elJmsapacheactivemqsinkSinkConnector.properties | 34 --
.../CamelJmsapacheactivemqsinkSinkConnector.java | 37 --
...elJmsapacheactivemqsinkSinkConnectorConfig.java | 65 ----
.../CamelJmsapacheactivemqsinkSinkTask.java | 37 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -----------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../kamelets/jms-apache-activemq-sink.kamelet.yaml | 95 -----
.../pom.xml | 148 --------
.../descriptors/connector-source.properties | 1 -
.../camel-jms-apache-activemq-source-source.json | 46 ---
...sapacheactivemqsourceSourceConnector.properties | 34 --
...amelJmsapacheactivemqsourceSourceConnector.java | 37 --
...sapacheactivemqsourceSourceConnectorConfig.java | 65 ----
.../CamelJmsapacheactivemqsourceSourceTask.java | 37 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -----------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../jms-apache-activemq-source.kamelet.yaml | 95 -----
.../pom.xml | 4 +-
.../camel-jms-apache-artemis-sink-sink.json | 2 +-
.../CamelJmsapacheartemissinkSinkConnector.java | 3 +-
...melJmsapacheartemissinkSinkConnectorConfig.java | 3 +-
.../CamelJmsapacheartemissinkSinkTask.java | 3 +-
.../kamelets/jms-apache-artemis-sink.kamelet.yaml | 10 +-
.../pom.xml | 4 +-
.../camel-jms-apache-artemis-source-source.json | 2 +-
...CamelJmsapacheartemissourceSourceConnector.java | 3 +-
...msapacheartemissourceSourceConnectorConfig.java | 3 +-
.../CamelJmsapacheartemissourceSourceTask.java | 3 +-
.../jms-apache-artemis-source.kamelet.yaml | 10 +-
.../camel-jms-ibm-mq-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-jms-ibm-mq-sink-sink.json | 8 +-
.../CamelJmsibmmqsinkSinkConnector.java | 3 +-
.../CamelJmsibmmqsinkSinkConnectorConfig.java | 7 +-
.../jmsibmmqsink/CamelJmsibmmqsinkSinkTask.java | 3 +-
.../kamelets/jms-ibm-mq-sink.kamelet.yaml | 34 +-
.../pom.xml | 2 +-
.../resources/camel-jms-ibm-mq-source-source.json | 8 +-
.../CamelJmsibmmqsourceSourceConnector.java | 3 +-
.../CamelJmsibmmqsourceSourceConnectorConfig.java | 7 +-
.../CamelJmsibmmqsourceSourceTask.java | 3 +-
.../kamelets/jms-ibm-mq-source.kamelet.yaml | 34 +-
...mel-kafka-connector-fix-dependencies.properties | 6 +-
.../pom.xml | 4 +-
.../camel-kafka-not-secured-sink-sink.json | 2 +-
.../CamelKafkanotsecuredsinkSinkConnector.java | 3 +-
...amelKafkanotsecuredsinkSinkConnectorConfig.java | 3 +-
.../CamelKafkanotsecuredsinkSinkTask.java | 3 +-
.../kamelets/kafka-not-secured-sink.kamelet.yaml | 19 +-
.../pom.xml | 11 +-
.../camel-kafka-not-secured-source-source.json | 9 +-
.../CamelKafkanotsecuredsourceSourceConnector.java | 3 +-
...KafkanotsecuredsourceSourceConnectorConfig.java | 7 +-
.../CamelKafkanotsecuredsourceSourceTask.java | 3 +-
.../kamelets/kafka-not-secured-source.kamelet.yaml | 21 +-
.../pom.xml | 16 +-
.../descriptors/connector-sink.properties | 1 +
.../resources/camel-kafka-scram-sink-sink.json | 51 +++
.../src/main/assembly/package.xml | 0
.../CamelKafkascramsinkSinkConnector.properties} | 12 +-
.../CamelKafkascramsinkSinkConnector.java} | 9 +-
.../CamelKafkascramsinkSinkConnectorConfig.java | 68 ++++
.../CamelKafkascramsinkSinkTask.java} | 9 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../kamelets/kafka-scram-sink.kamelet.yaml} | 15 +-
.../pom.xml | 10 +-
.../descriptors/connector-source.properties | 1 +
.../camel-kafka-scram-source-source.json} | 64 ++--
.../src/main/assembly/package.xml | 0
...amelKafkascramsourceSourceConnector.properties} | 12 +-
.../CamelKafkascramsourceSourceConnector.java} | 9 +-
...CamelKafkascramsourceSourceConnectorConfig.java | 92 +++++
.../CamelKafkascramsourceSourceTask.java} | 9 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../kamelets/kafka-scram-source.kamelet.yaml} | 26 +-
.../camel-kafka-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-kafka-sink-sink.json | 4 +-
.../kafkasink/CamelKafkasinkSinkConnector.java | 3 +-
.../CamelKafkasinkSinkConnectorConfig.java | 3 +-
.../kafkasink/CamelKafkasinkSinkTask.java | 3 +-
.../resources/kamelets/kafka-sink.kamelet.yaml | 7 +-
.../camel-kafka-source-kafka-connector/pom.xml | 4 +-
.../resources/camel-kafka-source-source.json | 6 +-
.../CamelKafkasourceSourceConnector.java | 3 +-
.../CamelKafkasourceSourceConnectorConfig.java | 5 +-
.../kafkasource/CamelKafkasourceSourceTask.java | 3 +-
.../resources/kamelets/kafka-source.kamelet.yaml | 16 +-
.../camel-kafka-ssl-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-kafka-ssl-sink-sink.json | 2 +-
.../CamelKafkasslsinkSinkConnector.java | 3 +-
.../CamelKafkasslsinkSinkConnectorConfig.java | 3 +-
.../kafkasslsink/CamelKafkasslsinkSinkTask.java | 3 +-
.../resources/kamelets/kafka-ssl-sink.kamelet.yaml | 32 +-
.../camel-kafka-ssl-source-kafka-connector/pom.xml | 4 +-
.../resources/camel-kafka-ssl-source-source.json | 4 +-
.../CamelKafkasslsourceSourceConnector.java | 3 +-
.../CamelKafkasslsourceSourceConnectorConfig.java | 5 +-
.../CamelKafkasslsourceSourceTask.java | 3 +-
.../kamelets/kafka-ssl-source.kamelet.yaml | 63 ++--
.../pom.xml | 2 +-
.../camel-kubernetes-namespaces-source-source.json | 2 +-
...lKubernetesnamespacessourceSourceConnector.java | 3 +-
...netesnamespacessourceSourceConnectorConfig.java | 3 +-
.../CamelKubernetesnamespacessourceSourceTask.java | 3 +-
.../kubernetes-namespaces-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-kubernetes-nodes-source-source.json | 2 +-
.../CamelKubernetesnodessourceSourceConnector.java | 3 +-
...KubernetesnodessourceSourceConnectorConfig.java | 3 +-
.../CamelKubernetesnodessourceSourceTask.java | 3 +-
.../kamelets/kubernetes-nodes-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-kubernetes-pods-source-source.json | 2 +-
.../CamelKubernetespodssourceSourceConnector.java | 3 +-
...lKubernetespodssourceSourceConnectorConfig.java | 3 +-
.../CamelKubernetespodssourceSourceTask.java | 3 +-
.../kamelets/kubernetes-pods-source.kamelet.yaml | 3 +-
connectors/camel-log-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-log-sink-sink.json | 2 +-
.../logsink/CamelLogsinkSinkConnector.java | 3 +-
.../logsink/CamelLogsinkSinkConnectorConfig.java | 3 +-
.../logsink/CamelLogsinkSinkTask.java | 3 +-
.../main/resources/kamelets/log-sink.kamelet.yaml | 3 +-
.../camel-mail-imap-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-mail-imap-source-source.json | 2 +-
.../CamelMailimapsourceSourceConnector.java | 3 +-
.../CamelMailimapsourceSourceConnectorConfig.java | 3 +-
.../CamelMailimapsourceSourceTask.java | 3 +-
.../kamelets/mail-imap-source.kamelet.yaml | 3 +-
connectors/camel-mail-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-mail-sink-sink.json | 2 +-
.../mailsink/CamelMailsinkSinkConnector.java | 3 +-
.../mailsink/CamelMailsinkSinkConnectorConfig.java | 3 +-
.../mailsink/CamelMailsinkSinkTask.java | 3 +-
.../main/resources/kamelets/mail-sink.kamelet.yaml | 3 +-
.../camel-mariadb-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-mariadb-sink-sink.json | 2 +-
.../mariadbsink/CamelMariadbsinkSinkConnector.java | 3 +-
.../CamelMariadbsinkSinkConnectorConfig.java | 3 +-
.../mariadbsink/CamelMariadbsinkSinkTask.java | 3 +-
.../resources/kamelets/mariadb-sink.kamelet.yaml | 17 +-
.../camel-mariadb-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-mariadb-source-source.json | 2 +-
.../CamelMariadbsourceSourceConnector.java | 3 +-
.../CamelMariadbsourceSourceConnectorConfig.java | 3 +-
.../CamelMariadbsourceSourceTask.java | 3 +-
.../resources/kamelets/mariadb-source.kamelet.yaml | 17 +-
.../camel-minio-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-minio-sink-sink.json | 2 +-
.../miniosink/CamelMiniosinkSinkConnector.java | 3 +-
.../CamelMiniosinkSinkConnectorConfig.java | 3 +-
.../miniosink/CamelMiniosinkSinkTask.java | 3 +-
.../resources/kamelets/minio-sink.kamelet.yaml | 3 +-
.../camel-minio-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-minio-source-source.json | 2 +-
.../CamelMiniosourceSourceConnector.java | 3 +-
.../CamelMiniosourceSourceConnectorConfig.java | 3 +-
.../miniosource/CamelMiniosourceSourceTask.java | 3 +-
.../resources/kamelets/minio-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
...camel-mongodb-changes-stream-source-source.json | 16 +-
...lMongodbchangesstreamsourceSourceConnector.java | 3 +-
...dbchangesstreamsourceSourceConnectorConfig.java | 11 +-
.../CamelMongodbchangesstreamsourceSourceTask.java | 3 +-
.../mongodb-changes-stream-source.kamelet.yaml | 29 +-
.../camel-mongodb-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-mongodb-sink-sink.json | 18 +-
.../mongodbsink/CamelMongodbsinkSinkConnector.java | 3 +-
.../CamelMongodbsinkSinkConnectorConfig.java | 13 +-
.../mongodbsink/CamelMongodbsinkSinkTask.java | 3 +-
.../resources/kamelets/mongodb-sink.kamelet.yaml | 34 +-
.../camel-mongodb-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-mongodb-source-source.json | 16 +-
.../CamelMongodbsourceSourceConnector.java | 3 +-
.../CamelMongodbsourceSourceConnectorConfig.java | 11 +-
.../CamelMongodbsourceSourceTask.java | 3 +-
.../resources/kamelets/mongodb-source.kamelet.yaml | 29 +-
connectors/camel-mqtt-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-mqtt-sink-sink.json | 2 +-
.../mqttsink/CamelMqttsinkSinkConnector.java | 3 +-
.../mqttsink/CamelMqttsinkSinkConnectorConfig.java | 3 +-
.../mqttsink/CamelMqttsinkSinkTask.java | 3 +-
.../main/resources/kamelets/mqtt-sink.kamelet.yaml | 3 +-
.../camel-mqtt-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-mqtt-source-source.json | 2 +-
.../mqttsource/CamelMqttsourceSourceConnector.java | 3 +-
.../CamelMqttsourceSourceConnectorConfig.java | 3 +-
.../mqttsource/CamelMqttsourceSourceTask.java | 3 +-
.../resources/kamelets/mqtt-source.kamelet.yaml | 3 +-
.../camel-mqtt5-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-mqtt5-sink-sink.json | 2 +-
.../mqtt5sink/CamelMqtt5sinkSinkConnector.java | 3 +-
.../CamelMqtt5sinkSinkConnectorConfig.java | 3 +-
.../mqtt5sink/CamelMqtt5sinkSinkTask.java | 3 +-
.../resources/kamelets/mqtt5-sink.kamelet.yaml | 3 +-
.../camel-mqtt5-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-mqtt5-source-source.json | 2 +-
.../CamelMqtt5sourceSourceConnector.java | 3 +-
.../CamelMqtt5sourceSourceConnectorConfig.java | 3 +-
.../mqtt5source/CamelMqtt5sourceSourceTask.java | 3 +-
.../resources/kamelets/mqtt5-source.kamelet.yaml | 3 +-
.../camel-mysql-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-mysql-sink-sink.json | 2 +-
.../mysqlsink/CamelMysqlsinkSinkConnector.java | 3 +-
.../CamelMysqlsinkSinkConnectorConfig.java | 3 +-
.../mysqlsink/CamelMysqlsinkSinkTask.java | 3 +-
.../resources/kamelets/mysql-sink.kamelet.yaml | 17 +-
.../camel-mysql-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-mysql-source-source.json | 2 +-
.../CamelMysqlsourceSourceConnector.java | 3 +-
.../CamelMysqlsourceSourceConnectorConfig.java | 3 +-
.../mysqlsource/CamelMysqlsourceSourceTask.java | 3 +-
.../resources/kamelets/mysql-source.kamelet.yaml | 17 +-
connectors/camel-nats-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-nats-sink-sink.json | 2 +-
.../natssink/CamelNatssinkSinkConnector.java | 3 +-
.../natssink/CamelNatssinkSinkConnectorConfig.java | 3 +-
.../natssink/CamelNatssinkSinkTask.java | 3 +-
.../main/resources/kamelets/nats-sink.kamelet.yaml | 3 +-
.../camel-nats-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-nats-source-source.json | 2 +-
.../natssource/CamelNatssourceSourceConnector.java | 3 +-
.../CamelNatssourceSourceConnectorConfig.java | 3 +-
.../natssource/CamelNatssourceSourceTask.java | 3 +-
.../resources/kamelets/nats-source.kamelet.yaml | 3 +-
.../camel-netty-http-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-netty-http-sink.json | 42 ++-
.../resources/camel-netty-http-source.json | 19 +-
.../nettyhttp/CamelNettyhttpSinkConnector.java | 3 +-
.../CamelNettyhttpSinkConnectorConfig.java | 27 +-
.../nettyhttp/CamelNettyhttpSinkTask.java | 3 +-
.../nettyhttp/CamelNettyhttpSourceConnector.java | 3 +-
.../CamelNettyhttpSourceConnectorConfig.java | 13 +-
.../nettyhttp/CamelNettyhttpSourceTask.java | 3 +-
connectors/camel-netty-kafka-connector/pom.xml | 2 +-
.../src/generated/resources/camel-netty-sink.json | 42 ++-
.../generated/resources/camel-netty-source.json | 19 +-
.../netty/CamelNettySinkConnector.java | 3 +-
.../netty/CamelNettySinkConnectorConfig.java | 27 +-
.../kafkaconnector/netty/CamelNettySinkTask.java | 3 +-
.../netty/CamelNettySourceConnector.java | 3 +-
.../netty/CamelNettySourceConnectorConfig.java | 13 +-
.../kafkaconnector/netty/CamelNettySourceTask.java | 3 +-
.../pom.xml | 2 +-
.../resources/camel-oracle-database-sink-sink.json | 2 +-
.../CamelOracledatabasesinkSinkConnector.java | 3 +-
...CamelOracledatabasesinkSinkConnectorConfig.java | 3 +-
.../CamelOracledatabasesinkSinkTask.java | 3 +-
.../kamelets/oracle-database-sink.kamelet.yaml | 17 +-
.../pom.xml | 2 +-
.../camel-oracle-database-source-source.json | 2 +-
.../CamelOracledatabasesourceSourceConnector.java | 3 +-
...lOracledatabasesourceSourceConnectorConfig.java | 3 +-
.../CamelOracledatabasesourceSourceTask.java | 3 +-
.../kamelets/oracle-database-source.kamelet.yaml | 17 +-
.../camel-postgresql-sink-kafka-connector/pom.xml | 4 +-
.../resources/camel-postgresql-sink-sink.json | 2 +-
.../CamelPostgresqlsinkSinkConnector.java | 3 +-
.../CamelPostgresqlsinkSinkConnectorConfig.java | 3 +-
.../CamelPostgresqlsinkSinkTask.java | 3 +-
.../kamelets/postgresql-sink.kamelet.yaml | 19 +-
.../pom.xml | 4 +-
.../resources/camel-postgresql-source-source.json | 2 +-
.../CamelPostgresqlsourceSourceConnector.java | 3 +-
...CamelPostgresqlsourceSourceConnectorConfig.java | 3 +-
.../CamelPostgresqlsourceSourceTask.java | 3 +-
.../kamelets/postgresql-source.kamelet.yaml | 19 +-
.../camel-pulsar-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-pulsar-sink-sink.json | 8 +-
.../CamelPulsarsinkSinkConnector.properties | 2 +-
.../pulsarsink/CamelPulsarsinkSinkConnector.java | 3 +-
.../CamelPulsarsinkSinkConnectorConfig.java | 9 +-
.../pulsarsink/CamelPulsarsinkSinkTask.java | 3 +-
.../resources/kamelets/pulsar-sink.kamelet.yaml | 14 +-
.../camel-pulsar-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-pulsar-source-source.json | 10 +-
.../CamelPulsarsourceSourceConnector.properties | 2 +-
.../CamelPulsarsourceSourceConnector.java | 3 +-
.../CamelPulsarsourceSourceConnectorConfig.java | 11 +-
.../pulsarsource/CamelPulsarsourceSourceTask.java | 3 +-
.../resources/kamelets/pulsar-source.kamelet.yaml | 17 +-
.../camel-rabbitmq-source-kafka-connector/pom.xml | 143 --------
.../descriptors/connector-source.properties | 1 -
.../resources/camel-rabbitmq-source-source.json | 56 ---
.../src/main/assembly/package.xml | 56 ---
.../CamelRabbitmqsourceSourceConnector.properties | 34 --
.../CamelRabbitmqsourceSourceConnector.java | 35 --
.../CamelRabbitmqsourceSourceConnectorConfig.java | 73 ----
.../CamelRabbitmqsourceSourceTask.java | 37 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -----------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../kamelets/rabbitmq-source.kamelet.yaml | 89 -----
.../camel-redis-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-redis-sink-sink.json | 2 +-
.../redissink/CamelRedissinkSinkConnector.java | 3 +-
.../CamelRedissinkSinkConnectorConfig.java | 3 +-
.../redissink/CamelRedissinkSinkTask.java | 3 +-
.../resources/kamelets/redis-sink.kamelet.yaml | 3 +-
.../camel-redis-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-redis-source-source.json | 2 +-
.../CamelRedissourceSourceConnector.java | 3 +-
.../CamelRedissourceSourceConnectorConfig.java | 3 +-
.../redissource/CamelRedissourceSourceTask.java | 3 +-
.../resources/kamelets/redis-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-rest-openapi-sink-sink.json | 2 +-
.../CamelRestopenapisinkSinkConnector.java | 3 +-
.../CamelRestopenapisinkSinkConnectorConfig.java | 3 +-
.../CamelRestopenapisinkSinkTask.java | 3 +-
.../kamelets/rest-openapi-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-salesforce-create-sink-sink.json | 2 +-
.../CamelSalesforcecreatesinkSinkConnector.java | 3 +-
...melSalesforcecreatesinkSinkConnectorConfig.java | 3 +-
.../CamelSalesforcecreatesinkSinkTask.java | 3 +-
.../kamelets/salesforce-create-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-salesforce-delete-sink-sink.json | 2 +-
.../CamelSalesforcedeletesinkSinkConnector.java | 3 +-
...melSalesforcedeletesinkSinkConnectorConfig.java | 3 +-
.../CamelSalesforcedeletesinkSinkTask.java | 3 +-
.../kamelets/salesforce-delete-sink.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../resources/camel-salesforce-source-source.json | 4 +-
.../CamelSalesforcesourceSourceConnector.java | 3 +-
...CamelSalesforcesourceSourceConnectorConfig.java | 5 +-
.../CamelSalesforcesourceSourceTask.java | 3 +-
.../kamelets/salesforce-source.kamelet.yaml | 6 +-
.../pom.xml | 14 +-
.../camel-salesforce-update-sink-sink.json | 16 +-
...melSalesforceupdatesinkSinkConnector.properties | 4 -
.../CamelSalesforceupdatesinkSinkConnector.java | 3 +-
...melSalesforceupdatesinkSinkConnectorConfig.java | 11 +-
.../CamelSalesforceupdatesinkSinkTask.java | 3 +-
.../kamelets/salesforce-update-sink.kamelet.yaml | 42 +--
connectors/camel-scp-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-scp-sink-sink.json | 2 +-
.../scpsink/CamelScpsinkSinkConnector.java | 3 +-
.../scpsink/CamelScpsinkSinkConnectorConfig.java | 3 +-
.../scpsink/CamelScpsinkSinkTask.java | 3 +-
.../main/resources/kamelets/scp-sink.kamelet.yaml | 3 +-
connectors/camel-sftp-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-sftp-sink-sink.json | 11 +-
.../sftpsink/CamelSftpsinkSinkConnector.java | 3 +-
.../sftpsink/CamelSftpsinkSinkConnectorConfig.java | 9 +-
.../sftpsink/CamelSftpsinkSinkTask.java | 3 +-
.../main/resources/kamelets/sftp-sink.kamelet.yaml | 16 +-
.../camel-sftp-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-sftp-source-source.json | 16 +-
.../sftpsource/CamelSftpsourceSourceConnector.java | 3 +-
.../CamelSftpsourceSourceConnectorConfig.java | 11 +-
.../sftpsource/CamelSftpsourceSourceTask.java | 3 +-
.../resources/kamelets/sftp-source.kamelet.yaml | 19 +-
connectors/camel-sjms2-kafka-connector/pom.xml | 7 +-
.../src/generated/resources/camel-sjms2-sink.json | 12 +-
.../generated/resources/camel-sjms2-source.json | 15 +-
.../sjms2/CamelSjms2SinkConnector.java | 3 +-
.../sjms2/CamelSjms2SinkConnectorConfig.java | 13 +-
.../kafkaconnector/sjms2/CamelSjms2SinkTask.java | 3 +-
.../sjms2/CamelSjms2SourceConnector.java | 3 +-
.../sjms2/CamelSjms2SourceConnectorConfig.java | 13 +-
.../kafkaconnector/sjms2/CamelSjms2SourceTask.java | 3 +-
.../camel-slack-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-slack-sink-sink.json | 2 +-
.../slacksink/CamelSlacksinkSinkConnector.java | 3 +-
.../CamelSlacksinkSinkConnectorConfig.java | 3 +-
.../slacksink/CamelSlacksinkSinkTask.java | 3 +-
.../resources/kamelets/slack-sink.kamelet.yaml | 3 +-
.../camel-slack-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-slack-source-source.json | 2 +-
.../CamelSlacksourceSourceConnector.java | 3 +-
.../CamelSlacksourceSourceConnectorConfig.java | 3 +-
.../slacksource/CamelSlacksourceSourceTask.java | 3 +-
.../resources/kamelets/slack-source.kamelet.yaml | 3 +-
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-solr-sink-sink.json | 44 ---
.../src/main/assembly/package.xml | 56 ---
.../examples/CamelSolrsinkSinkConnector.properties | 34 --
.../solrsink/CamelSolrsinkSinkConnector.java | 35 --
.../solrsink/CamelSolrsinkSinkConnectorConfig.java | 64 ----
.../solrsink/CamelSolrsinkSinkTask.java | 37 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -----------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../main/resources/kamelets/solr-sink.kamelet.yaml | 93 -----
.../camel-solr-source-kafka-connector/pom.xml | 155 ---------
.../descriptors/connector-source.properties | 1 -
.../resources/camel-solr-source-source.json | 50 ---
.../src/main/assembly/package.xml | 56 ---
.../CamelSolrsourceSourceConnector.properties | 38 --
.../solrsource/CamelSolrsourceSourceConnector.java | 35 --
.../CamelSolrsourceSourceConnectorConfig.java | 68 ----
.../solrsource/CamelSolrsourceSourceTask.java | 37 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -----------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../resources/kamelets/solr-source.kamelet.yaml | 103 ------
.../camel-splunk-hec-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-splunk-hec-sink-sink.json | 2 +-
.../CamelSplunkhecsinkSinkConnector.java | 3 +-
.../CamelSplunkhecsinkSinkConnectorConfig.java | 3 +-
.../splunkhecsink/CamelSplunkhecsinkSinkTask.java | 3 +-
.../kamelets/splunk-hec-sink.kamelet.yaml | 3 +-
.../camel-splunk-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-splunk-sink-sink.json | 2 +-
.../splunksink/CamelSplunksinkSinkConnector.java | 3 +-
.../CamelSplunksinkSinkConnectorConfig.java | 3 +-
.../splunksink/CamelSplunksinkSinkTask.java | 3 +-
.../resources/kamelets/splunk-sink.kamelet.yaml | 3 +-
.../camel-splunk-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-splunk-source-source.json | 2 +-
.../CamelSplunksourceSourceConnector.java | 3 +-
.../CamelSplunksourceSourceConnectorConfig.java | 3 +-
.../splunksource/CamelSplunksourceSourceTask.java | 3 +-
.../resources/kamelets/splunk-source.kamelet.yaml | 3 +-
.../camel-sqlserver-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-sqlserver-sink-sink.json | 2 +-
.../CamelSqlserversinkSinkConnector.java | 3 +-
.../CamelSqlserversinkSinkConnectorConfig.java | 3 +-
.../sqlserversink/CamelSqlserversinkSinkTask.java | 3 +-
.../resources/kamelets/sqlserver-sink.kamelet.yaml | 17 +-
.../camel-sqlserver-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-sqlserver-source-source.json | 2 +-
.../CamelSqlserversourceSourceConnector.java | 3 +-
.../CamelSqlserversourceSourceConnectorConfig.java | 3 +-
.../CamelSqlserversourceSourceTask.java | 3 +-
.../kamelets/sqlserver-source.kamelet.yaml | 17 +-
connectors/camel-ssh-sink-kafka-connector/pom.xml | 2 +-
.../generated/resources/camel-ssh-sink-sink.json | 2 +-
.../sshsink/CamelSshsinkSinkConnector.java | 3 +-
.../sshsink/CamelSshsinkSinkConnectorConfig.java | 3 +-
.../sshsink/CamelSshsinkSinkTask.java | 3 +-
.../main/resources/kamelets/ssh-sink.kamelet.yaml | 3 +-
.../camel-ssh-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-ssh-source-source.json | 2 +-
.../sshsource/CamelSshsourceSourceConnector.java | 3 +-
.../CamelSshsourceSourceConnectorConfig.java | 3 +-
.../sshsource/CamelSshsourceSourceTask.java | 3 +-
.../resources/kamelets/ssh-source.kamelet.yaml | 3 +-
connectors/camel-syslog-kafka-connector/pom.xml | 2 +-
.../camel-telegram-sink-kafka-connector/pom.xml | 2 +-
.../resources/camel-telegram-sink-sink.json | 4 +-
.../CamelTelegramsinkSinkConnector.java | 3 +-
.../CamelTelegramsinkSinkConnectorConfig.java | 5 +-
.../telegramsink/CamelTelegramsinkSinkTask.java | 3 +-
.../resources/kamelets/telegram-sink.kamelet.yaml | 8 +-
.../camel-telegram-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-telegram-source-source.json | 4 +-
.../CamelTelegramsourceSourceConnector.properties | 2 +-
.../CamelTelegramsourceSourceConnector.java | 3 +-
.../CamelTelegramsourceSourceConnectorConfig.java | 5 +-
.../CamelTelegramsourceSourceTask.java | 3 +-
.../kamelets/telegram-source.kamelet.yaml | 5 +-
.../camel-timer-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-timer-source-source.json | 2 +-
.../CamelTimersourceSourceConnector.java | 3 +-
.../CamelTimersourceSourceConnectorConfig.java | 3 +-
.../timersource/CamelTimersourceSourceTask.java | 3 +-
.../resources/kamelets/timer-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-twitter-directmessage-source-source.json | 2 +-
...lTwitterdirectmessagesourceSourceConnector.java | 3 +-
...erdirectmessagesourceSourceConnectorConfig.java | 3 +-
.../CamelTwitterdirectmessagesourceSourceTask.java | 3 +-
.../twitter-directmessage-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-twitter-search-source-source.json | 2 +-
.../CamelTwittersearchsourceSourceConnector.java | 3 +-
...elTwittersearchsourceSourceConnectorConfig.java | 3 +-
.../CamelTwittersearchsourceSourceTask.java | 3 +-
.../kamelets/twitter-search-source.kamelet.yaml | 3 +-
.../pom.xml | 2 +-
.../camel-twitter-timeline-source-source.json | 2 +-
.../CamelTwittertimelinesourceSourceConnector.java | 3 +-
...TwittertimelinesourceSourceConnectorConfig.java | 3 +-
.../CamelTwittertimelinesourceSourceTask.java | 3 +-
.../kamelets/twitter-timeline-source.kamelet.yaml | 3 +-
.../camel-webhook-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-webhook-source-source.json | 2 +-
.../CamelWebhooksourceSourceConnector.java | 3 +-
.../CamelWebhooksourceSourceConnectorConfig.java | 3 +-
.../CamelWebhooksourceSourceTask.java | 3 +-
.../resources/kamelets/webhook-source.kamelet.yaml | 3 +-
.../descriptors/connector-source.properties | 1 -
.../resources/camel-websocket-source-source.json | 117 -------
.../src/main/assembly/package.xml | 56 ---
.../CamelWebsocketsourceSourceConnector.properties | 32 --
.../CamelWebsocketsourceSourceConnector.java | 35 --
.../CamelWebsocketsourceSourceConnectorConfig.java | 105 ------
.../CamelWebsocketsourceSourceTask.java | 37 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -----------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../kamelets/websocket-source.kamelet.yaml | 126 -------
.../camel-wttrin-source-kafka-connector/pom.xml | 2 +-
.../resources/camel-wttrin-source-source.json | 2 +-
.../CamelWttrinsourceSourceConnector.java | 3 +-
.../CamelWttrinsourceSourceConnectorConfig.java | 3 +-
.../wttrinsource/CamelWttrinsourceSourceTask.java | 3 +-
.../resources/kamelets/wttrin-source.kamelet.yaml | 3 +-
connectors/pom.xml | 17 +-
core/pom.xml | 5 +-
.../camel/kafkaconnector/CamelSourceTask.java | 3 +-
.../utils/CamelKafkaConnectMain.java | 2 +-
.../camel/kafkaconnector/utils/TaskHelper.java | 3 +-
distribution/pom.xml | 2 +-
docs/modules/ROOT/nav.adoc | 24 +-
docs/modules/ROOT/pages/reference/index.adoc | 14 +-
mvnw | 224 ++++++------
mvnw.cmd | 387 +++++++++++----------
parent/pom.xml | 36 +-
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 +-
tests/itests-common-http/pom.xml | 2 +-
tests/itests-common/pom.xml | 2 +-
.../services/kafkaconnect/KafkaConnectRunner.java | 7 +-
tests/itests-couchbase/pom.xml | 2 +-
tests/itests-cxf/pom.xml | 46 +--
.../cxf/sink/SinkJaxWsServiceConfigurator.java | 3 +-
tests/itests-cxfrs/pom.xml | 51 +--
.../camel/kafkaconnector/cxfrs/Customer.java | 3 +-
.../cxfrs/CustomerServiceResource.java | 14 +-
tests/itests-elasticsearch/pom.xml | 11 +-
.../elasticsearch/clients/ElasticSearchClient.java | 88 +++--
.../elasticsearch/common/ElasticSearchCommon.java | 12 +
.../ElasticSearchLocalContainerServiceHack.java | 60 ++++
.../sink/CamelElasticSearchPropertyFactory.java | 8 +-
.../sink/CamelSinkElasticSearchITCase.java | 45 +--
tests/itests-file/pom.xml | 2 +-
tests/itests-google-pubsub/pom.xml | 2 +-
tests/itests-hdfs/pom.xml | 12 +-
.../hdfs/sink/CamelSinkHDFSITCase.java | 3 +-
tests/itests-http/pom.xml | 4 +-
.../http/sink/CamelSinkHTTPITCase.java | 9 +-
.../http/sink/HTTPTestValidationHandler.java | 52 +--
tests/itests-https/pom.xml | 2 +-
.../https/sink/CamelSinkHTTPSITCase.java | 4 +-
tests/itests-jdbc/pom.xml | 5 +-
tests/itests-mongodb/pom.xml | 9 +-
.../common/CkcMongoDBLocalContainerService.java | 2 +
.../mongodb/sink/CamelMongoDBPropertyFactory.java | 9 +
.../source/CamelMongoDBPropertyFactory.java | 9 +
tests/itests-netty-http/pom.xml | 3 +-
tests/itests-netty/pom.xml | 2 +-
tests/itests-parent/pom.xml | 7 +-
tests/itests-rabbitmq/pom.xml | 79 -----
.../rabbitmq/clients/RabbitMQClient.java | 182 ----------
.../sink/CamelRabbitMQPropertyFactory.java | 78 -----
.../rabbitmq/sink/RabbitMQSinkITCase.java | 133 -------
.../source/CamelRabbitMQPropertyFactory.java | 59 ----
.../rabbitmq/source/RabbitMQSourceITCase.java | 117 -------
tests/itests-salesforce/pom.xml | 2 +-
tests/itests-sjms2/pom.xml | 10 +-
.../kafkaconnector/sjms2/clients/JMSClient.java | 23 +-
.../sjms2/sink/CamelSinkIdempotentJMSITCase.java | 9 +-
.../sjms2/sink/CamelSinkJMSITCase.java | 9 +-
tests/itests-slack/pom.xml | 2 +-
tests/itests-sql/pom.xml | 4 +-
tests/itests-ssh/pom.xml | 2 +-
tests/itests-syslog/pom.xml | 2 +-
tests/itests-timer/pom.xml | 2 +-
tests/perf-tests-rabbitmq/pom.xml | 88 -----
.../source/CamelRabbitMQPropertyFactory.java | 76 ----
.../source/RabbitMQSourcePerformanceITCase.java | 69 ----
tests/pom.xml | 6 +-
.../pom.xml | 4 +-
.../pom.xml | 5 +-
.../pom.xml | 18 +-
...mel-kafka-connector-fix-dependencies.properties | 6 +-
.../maven_project/pom.xml | 5 +-
...mel-kafka-connector-fix-dependencies.properties | 6 +-
...a-connector-kamelet-fix-dependencies.properties | 6 +-
tooling/camel-kafka-connector-model/pom.xml | 2 +-
tooling/pom.xml | 9 +-
1397 files changed, 5243 insertions(+), 10145 deletions(-)
delete mode 100644 .mvn/wrapper/MavenWrapperDownloader.java
create mode 100644 Jenkinsfile.deploy
create mode 100644
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-cosmosdb-sink-sink.json
create mode 100644
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-datalake-sink-sink.json
create mode 100644
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-datalake-source-source.json
create mode 100644
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-graphql-sink-sink.json
create mode 100644
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-scram-sink-sink.json
copy
connectors/camel-kafka-source-kafka-connector/src/generated/resources/camel-kafka-source-source.json
=>
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-scram-source-source.json
(54%)
delete mode 100644
connectors/camel-aws-ddb-experimental-sink-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-ddb-experimental-sink-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-ddb-experimental-sink-kafka-connector/src/generated/resources/camel-aws-ddb-experimental-sink-sink.json
delete mode 100644
connectors/camel-aws-ddb-experimental-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddbexperimentalsink/CamelAwsddbexperimentalsinkSinkConnector.java
delete mode 100644
connectors/camel-aws-ddb-experimental-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddbexperimentalsink/CamelAwsddbexperimentalsinkSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-ddb-experimental-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddbexperimentalsink/CamelAwsddbexperimentalsinkSinkTask.java
delete mode 100644
connectors/camel-aws-ddb-experimental-sink-kafka-connector/src/main/resources/kamelets/aws-ddb-experimental-sink.kamelet.yaml
delete mode 100644
connectors/camel-aws-s3-experimental-source-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-s3-experimental-source-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-aws-s3-experimental-source-kafka-connector/src/generated/resources/camel-aws-s3-experimental-source-source.json
delete mode 100644
connectors/camel-aws-s3-experimental-source-kafka-connector/src/main/docs/examples/CamelAwss3experimentalsourceSourceConnector.properties
delete mode 100644
connectors/camel-aws-s3-experimental-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3experimentalsource/CamelAwss3experimentalsourceSourceConnector.java
delete mode 100644
connectors/camel-aws-s3-experimental-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3experimentalsource/CamelAwss3experimentalsourceSourceConnectorConfig.java
delete mode 100644
connectors/camel-aws-s3-experimental-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3experimentalsource/CamelAwss3experimentalsourceSourceTask.java
delete mode 100644
connectors/camel-aws-s3-experimental-source-kafka-connector/src/main/resources/kamelets/aws-s3-experimental-source.kamelet.yaml
rename connectors/{camel-solr-sink-kafka-connector =>
camel-azure-cosmosdb-sink-kafka-connector}/pom.xml (94%)
create mode 100644
connectors/camel-azure-cosmosdb-sink-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644
connectors/camel-azure-cosmosdb-sink-kafka-connector/src/generated/resources/camel-azure-cosmosdb-sink-sink.json
rename connectors/{camel-aws-ddb-experimental-sink-kafka-connector =>
camel-azure-cosmosdb-sink-kafka-connector}/src/main/assembly/package.xml (100%)
rename
connectors/{camel-aws-ddb-experimental-sink-kafka-connector/src/main/docs/examples/CamelAwsddbexperimentalsinkSinkConnector.properties
=>
camel-azure-cosmosdb-sink-kafka-connector/src/main/docs/examples/CamelAzurecosmosdbsinkSinkConnector.properties}
(72%)
copy
connectors/{camel-aws-cloudwatch-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awscloudwatchsink/CamelAwscloudwatchsinkSinkConnector.java
=>
camel-azure-cosmosdb-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurecosmosdbsink/CamelAzurecosmosdbsinkSinkConnector.java}
(83%)
create mode 100644
connectors/camel-azure-cosmosdb-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurecosmosdbsink/CamelAzurecosmosdbsinkSinkConnectorConfig.java
copy
connectors/{camel-aws-cloudwatch-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awscloudwatchsink/CamelAwscloudwatchsinkSinkTask.java
=>
camel-azure-cosmosdb-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurecosmosdbsink/CamelAzurecosmosdbsinkSinkTask.java}
(85%)
rename connectors/{camel-aws-ddb-experimental-sink-kafka-connector =>
camel-azure-cosmosdb-sink-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
rename connectors/{camel-aws-ddb-experimental-sink-kafka-connector =>
camel-azure-cosmosdb-sink-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
copy
connectors/{camel-azure-cosmosdb-source-kafka-connector/src/main/resources/kamelets/azure-cosmosdb-source.kamelet.yaml
=>
camel-azure-cosmosdb-sink-kafka-connector/src/main/resources/kamelets/azure-cosmosdb-sink.kamelet.yaml}
(73%)
copy connectors/{camel-timer-source-kafka-connector =>
camel-graphql-sink-kafka-connector}/pom.xml (94%)
create mode 100644
connectors/camel-graphql-sink-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644
connectors/camel-graphql-sink-kafka-connector/src/generated/resources/camel-graphql-sink-sink.json
rename connectors/{camel-aws-s3-experimental-source-kafka-connector =>
camel-graphql-sink-kafka-connector}/src/main/assembly/package.xml (100%)
copy
connectors/{camel-aws2-iam-kafka-connector/src/main/docs/examples/CamelAws2iamSinkConnector.properties
=>
camel-graphql-sink-kafka-connector/src/main/docs/examples/CamelGraphqlsinkSinkConnector.properties}
(84%)
copy
connectors/{camel-dropbox-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/dropboxsink/CamelDropboxsinkSinkConnector.java
=>
camel-graphql-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/graphqlsink/CamelGraphqlsinkSinkConnector.java}
(84%)
copy
connectors/{camel-exec-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/execsink/CamelExecsinkSinkConnectorConfig.java
=>
camel-graphql-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/graphqlsink/CamelGraphqlsinkSinkConnectorConfig.java}
(52%)
copy
connectors/{camel-aws-ses-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssessink/CamelAwssessinkSinkTask.java
=>
camel-graphql-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/graphqlsink/CamelGraphqlsinkSinkTask.java}
(85%)
rename connectors/{camel-aws-s3-experimental-source-kafka-connector =>
camel-graphql-sink-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
rename connectors/{camel-aws-s3-experimental-source-kafka-connector =>
camel-graphql-sink-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
copy
connectors/{camel-http-sink-kafka-connector/src/main/resources/kamelets/http-sink.kamelet.yaml
=>
camel-graphql-sink-kafka-connector/src/main/resources/kamelets/graphql-sink.kamelet.yaml}
(74%)
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/pom.xml
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/generated/resources/camel-jms-apache-activemq-sink-sink.json
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/main/docs/examples/CamelJmsapacheactivemqsinkSinkConnector.properties
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmsapacheactivemqsink/CamelJmsapacheactivemqsinkSinkConnector.java
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmsapacheactivemqsink/CamelJmsapacheactivemqsinkSinkConnectorConfig.java
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmsapacheactivemqsink/CamelJmsapacheactivemqsinkSinkTask.java
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-jms-apache-activemq-sink-kafka-connector/src/main/resources/kamelets/jms-apache-activemq-sink.kamelet.yaml
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/pom.xml
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/generated/resources/camel-jms-apache-activemq-source-source.json
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/main/docs/examples/CamelJmsapacheactivemqsourceSourceConnector.properties
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmsapacheactivemqsource/CamelJmsapacheactivemqsourceSourceConnector.java
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmsapacheactivemqsource/CamelJmsapacheactivemqsourceSourceConnectorConfig.java
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmsapacheactivemqsource/CamelJmsapacheactivemqsourceSourceTask.java
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-jms-apache-activemq-source-kafka-connector/src/main/resources/kamelets/jms-apache-activemq-source.kamelet.yaml
rename connectors/{camel-websocket-source-kafka-connector =>
camel-kafka-scram-sink-kafka-connector}/pom.xml (94%)
create mode 100644
connectors/camel-kafka-scram-sink-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644
connectors/camel-kafka-scram-sink-kafka-connector/src/generated/resources/camel-kafka-scram-sink-sink.json
rename connectors/{camel-jms-apache-activemq-sink-kafka-connector =>
camel-kafka-scram-sink-kafka-connector}/src/main/assembly/package.xml (100%)
copy
connectors/{camel-kafka-sink-kafka-connector/src/main/docs/examples/CamelKafkasinkSinkConnector.properties
=>
camel-kafka-scram-sink-kafka-connector/src/main/docs/examples/CamelKafkascramsinkSinkConnector.properties}
(83%)
copy
connectors/{camel-aws-sns-fifo-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssnsfifosink/CamelAwssnsfifosinkSinkConnector.java
=>
camel-kafka-scram-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkascramsink/CamelKafkascramsinkSinkConnector.java}
(84%)
create mode 100644
connectors/camel-kafka-scram-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkascramsink/CamelKafkascramsinkSinkConnectorConfig.java
copy
connectors/{camel-infinispan-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispansink/CamelInfinispansinkSinkTask.java
=>
camel-kafka-scram-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkascramsink/CamelKafkascramsinkSinkTask.java}
(85%)
copy LICENSE.txt =>
connectors/camel-kafka-scram-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt
(100%)
copy NOTICE.txt =>
connectors/camel-kafka-scram-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt
(100%)
copy
connectors/{camel-kafka-sink-kafka-connector/src/main/resources/kamelets/kafka-sink.kamelet.yaml
=>
camel-kafka-scram-sink-kafka-connector/src/main/resources/kamelets/kafka-scram-sink.kamelet.yaml}
(93%)
copy connectors/{camel-kafka-source-kafka-connector =>
camel-kafka-scram-source-kafka-connector}/pom.xml (94%)
create mode 100644
connectors/camel-kafka-scram-source-kafka-connector/src/generated/descriptors/connector-source.properties
copy
connectors/{camel-kafka-source-kafka-connector/src/generated/resources/camel-kafka-source-source.json
=>
camel-kafka-scram-source-kafka-connector/src/generated/resources/camel-kafka-scram-source-source.json}
(54%)
rename connectors/{camel-jms-apache-activemq-source-kafka-connector =>
camel-kafka-scram-source-kafka-connector}/src/main/assembly/package.xml (100%)
copy
connectors/{camel-kafka-source-kafka-connector/src/main/docs/examples/CamelKafkasourceSourceConnector.properties
=>
camel-kafka-scram-source-kafka-connector/src/main/docs/examples/CamelKafkascramsourceSourceConnector.properties}
(82%)
copy
connectors/{camel-google-mail-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlemailsource/CamelGooglemailsourceSourceConnector.java
=>
camel-kafka-scram-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkascramsource/CamelKafkascramsourceSourceConnector.java}
(85%)
create mode 100644
connectors/camel-kafka-scram-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkascramsource/CamelKafkascramsourceSourceConnectorConfig.java
copy
connectors/{camel-earthquake-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/earthquakesource/CamelEarthquakesourceSourceTask.java
=>
camel-kafka-scram-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkascramsource/CamelKafkascramsourceSourceTask.java}
(85%)
copy LICENSE.txt =>
connectors/camel-kafka-scram-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt
(100%)
copy NOTICE.txt =>
connectors/camel-kafka-scram-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt
(100%)
copy
connectors/{camel-kafka-source-kafka-connector/src/main/resources/kamelets/kafka-source.kamelet.yaml
=>
camel-kafka-scram-source-kafka-connector/src/main/resources/kamelets/kafka-scram-source.kamelet.yaml}
(91%)
delete mode 100644 connectors/camel-rabbitmq-source-kafka-connector/pom.xml
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/generated/resources/camel-rabbitmq-source-source.json
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/main/docs/examples/CamelRabbitmqsourceSourceConnector.properties
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmqsource/CamelRabbitmqsourceSourceConnector.java
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmqsource/CamelRabbitmqsourceSourceConnectorConfig.java
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/rabbitmqsource/CamelRabbitmqsourceSourceTask.java
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-rabbitmq-source-kafka-connector/src/main/resources/kamelets/rabbitmq-source.kamelet.yaml
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/generated/resources/camel-solr-sink-sink.json
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/main/docs/examples/CamelSolrsinkSinkConnector.properties
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrsink/CamelSolrsinkSinkConnector.java
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrsink/CamelSolrsinkSinkConnectorConfig.java
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrsink/CamelSolrsinkSinkTask.java
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-solr-sink-kafka-connector/src/main/resources/kamelets/solr-sink.kamelet.yaml
delete mode 100644 connectors/camel-solr-source-kafka-connector/pom.xml
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/generated/resources/camel-solr-source-source.json
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/main/docs/examples/CamelSolrsourceSourceConnector.properties
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrsource/CamelSolrsourceSourceConnector.java
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrsource/CamelSolrsourceSourceConnectorConfig.java
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/solrsource/CamelSolrsourceSourceTask.java
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-solr-source-kafka-connector/src/main/resources/kamelets/solr-source.kamelet.yaml
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/generated/resources/camel-websocket-source-source.json
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/main/docs/examples/CamelWebsocketsourceSourceConnector.properties
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/websocketsource/CamelWebsocketsourceSourceConnector.java
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/websocketsource/CamelWebsocketsourceSourceConnectorConfig.java
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/websocketsource/CamelWebsocketsourceSourceTask.java
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-websocket-source-kafka-connector/src/main/resources/kamelets/websocket-source.kamelet.yaml
create mode 100644
tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/common/ElasticSearchLocalContainerServiceHack.java
delete mode 100644 tests/itests-rabbitmq/pom.xml
delete mode 100644
tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/clients/RabbitMQClient.java
delete mode 100644
tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/CamelRabbitMQPropertyFactory.java
delete mode 100644
tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/sink/RabbitMQSinkITCase.java
delete mode 100644
tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/source/CamelRabbitMQPropertyFactory.java
delete mode 100644
tests/itests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/source/RabbitMQSourceITCase.java
delete mode 100644 tests/perf-tests-rabbitmq/pom.xml
delete mode 100644
tests/perf-tests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/source/CamelRabbitMQPropertyFactory.java
delete mode 100644
tests/perf-tests-rabbitmq/src/test/java/org/apache/camel/kafkaconnector/rabbitmq/source/RabbitMQSourcePerformanceITCase.java
