This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from d128b9a Updated CHANGELOG.md
new c824ad7 Adjusted catalog tests for camel 3.9.0
new 267ab14 Adjusted the code to CAMEL-16299
new 970d92d Upgrade Camel to 3.9.0
new df8294c Align to 3.9.0
new cd32688 Align to 3.9.0
new de9bacc Align to 3.9.0
new d660dd6 Align to 3.9.0
new 4d9cfd3 Regen
new d5a4d5f Align to 3.9.0
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../camel-atmosphere-websocket-sink.json | 21 -
.../camel-atmosphere-websocket-source.json | 28 +-
...nk.json => camel-aws-secrets-manager-sink.json} | 168 +++---
.../resources/connectors/camel-aws2-cw-sink.json | 26 +
.../resources/connectors/camel-aws2-ddb-sink.json | 26 +
.../connectors/camel-aws2-ddbstream-source.json | 26 +
.../resources/connectors/camel-aws2-ec2-sink.json | 26 +
.../resources/connectors/camel-aws2-ecs-sink.json | 26 +
.../resources/connectors/camel-aws2-eks-sink.json | 26 +
.../connectors/camel-aws2-eventbridge-sink.json | 26 +
.../resources/connectors/camel-aws2-iam-sink.json | 26 +
.../resources/connectors/camel-aws2-kms-sink.json | 26 +
.../connectors/camel-aws2-lambda-sink.json | 26 +
.../resources/connectors/camel-aws2-mq-sink.json | 26 +
.../resources/connectors/camel-aws2-msk-sink.json | 26 +
.../resources/connectors/camel-aws2-s3-sink.json | 4 +-
.../resources/connectors/camel-aws2-s3-source.json | 4 +-
.../resources/connectors/camel-aws2-ses-sink.json | 26 +
.../resources/connectors/camel-aws2-sns-sink.json | 30 +-
.../resources/connectors/camel-aws2-sqs-sink.json | 44 +-
.../connectors/camel-aws2-sqs-source.json | 34 +-
.../resources/connectors/camel-aws2-sts-sink.json | 26 +
.../connectors/camel-aws2-translate-sink.json | 26 +
.../resources/connectors/camel-file-sink.json | 2 +-
.../connectors/camel-freemarker-sink.json | 7 +
.../connectors/camel-google-bigquery-sql-sink.json | 12 +-
...-sink.json => camel-google-functions-sink.json} | 92 ++--
.../camel-google-mail-stream-source.json | 4 +-
.../connectors/camel-google-pubsub-sink.json | 16 +-
.../connectors/camel-google-pubsub-source.json | 16 +-
.../connectors/camel-google-storage-sink.json | 154 ++++++
.../connectors/camel-google-storage-source.json | 226 ++++----
.../resources/connectors/camel-http-sink.json | 114 +++-
.../resources/connectors/camel-https-sink.json | 114 +++-
.../resources/connectors/camel-jetty-source.json | 40 +-
.../resources/connectors/camel-kafka-source.json | 32 ++
.../connectors/camel-netty-http-sink.json | 14 +
.../connectors/camel-netty-http-source.json | 14 +
.../resources/connectors/camel-netty-sink.json | 14 +
.../resources/connectors/camel-netty-source.json | 14 +
.../resources/connectors/camel-resteasy-sink.json | 108 +++-
.../connectors/camel-resteasy-source.json | 89 ++-
.../resources/connectors/camel-servlet-source.json | 28 +-
.../resources/connectors/camel-slack-sink.json | 12 +
.../resources/connectors/camel-slack-source.json | 38 +-
.../resources/connectors/camel-smpp-sink.json | 4 +-
.../resources/connectors/camel-smpp-source.json | 4 +-
.../resources/connectors/camel-smpps-sink.json | 4 +-
.../resources/connectors/camel-smpps-source.json | 4 +-
.../resources/connectors/camel-splunk-sink.json | 6 +
.../connectors/camel-spring-rabbitmq-sink.json | 14 +
.../connectors/camel-spring-rabbitmq-source.json | 107 ++++
.../connectors/camel-vertx-http-sink.json | 14 +
.../connectors/camel-vertx-kafka-source.json | 20 +
.../resources/descriptors/connectors.properties | 32 +-
.../catalog/CamelKafkaConnectorCatalogTest.java | 2 +-
.../resources/camel-atmosphere-websocket-sink.json | 21 -
.../camel-atmosphere-websocket-source.json | 28 +-
...-atmosphere-websocket-kafka-sink-connector.adoc | 5 +-
...tmosphere-websocket-kafka-source-connector.adoc | 4 +-
...amelAtmospherewebsocketSinkConnectorConfig.java | 12 -
...elAtmospherewebsocketSourceConnectorConfig.java | 16 +-
.../descriptors/connector-sink.properties | 1 -
.../src/generated/resources/camel-aws-cw-sink.json | 202 -------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-cw-kafka-sink-connector.adoc | 80 ---
.../examples/CamelAwscwSinkConnector.properties | 33 --
.../awscw/CamelAwscwSinkConnectorConfig.java | 158 ------
.../kafkaconnector/awscw/CamelAwscwSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-ddb-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-ddb-sink.json | 254 ---------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-ddb-kafka-sink-connector.adoc | 84 ---
.../awsddb/CamelAwsddbSinkConnectorConfig.java | 174 ------
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../camel-aws-ddbstream-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-source.properties | 1 -
.../src/main/assembly/package.xml | 56 --
...camel-aws-ddbstream-kafka-source-connector.adoc | 96 ----
.../CamelAwsddbstreamSourceConnector.properties | 33 --
.../CamelAwsddbstreamSourceConnector.java | 35 --
.../CamelAwsddbstreamSourceConnectorConfig.java | 225 --------
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-ec2-sink.json | 192 -------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-ec2-kafka-sink-connector.adoc | 74 ---
.../examples/CamelAwsec2SinkConnector.properties | 37 --
.../awsec2/CamelAwsec2SinkConnector.java | 35 --
.../awsec2/CamelAwsec2SinkConnectorConfig.java | 134 -----
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-ecs-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-ecs-sink.json | 178 ------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-ecs-kafka-sink-connector.adoc | 74 ---
.../examples/CamelAwsecsSinkConnector.properties | 37 --
.../awsecs/CamelAwsecsSinkConnectorConfig.java | 134 -----
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-eks-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-eks-sink.json | 178 ------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-eks-kafka-sink-connector.adoc | 74 ---
.../examples/CamelAwseksSinkConnector.properties | 37 --
.../awseks/CamelAwseksSinkConnector.java | 35 --
.../awseks/CamelAwseksSinkConnectorConfig.java | 134 -----
.../kafkaconnector/awseks/CamelAwseksSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-iam-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-iam-sink.json | 196 -------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-iam-kafka-sink-connector.adoc | 74 ---
.../examples/CamelAwsiamSinkConnector.properties | 37 --
.../awsiam/CamelAwsiamSinkConnector.java | 35 --
.../awsiam/CamelAwsiamSinkConnectorConfig.java | 134 -----
.../kafkaconnector/awsiam/CamelAwsiamSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../resources/camel-aws-kinesis-firehose-sink.json | 154 ------
.../src/main/assembly/package.xml | 56 --
...-aws-kinesis-firehose-kafka-sink-connector.adoc | 72 ---
...CamelAwskinesisfirehoseSinkConnector.properties | 33 --
.../CamelAwskinesisfirehoseSinkConnector.java | 35 --
...CamelAwskinesisfirehoseSinkConnectorConfig.java | 129 -----
.../CamelAwskinesisfirehoseSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../camel-aws-kinesis-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../descriptors/connector-source.properties | 1 -
.../resources/camel-aws-kinesis-sink.json | 154 ------
.../resources/camel-aws-kinesis-source.json | 384 -------------
.../src/main/assembly/package.xml | 56 --
.../camel-aws-kinesis-kafka-sink-connector.adoc | 72 ---
.../camel-aws-kinesis-kafka-source-connector.adoc | 100 ----
.../CamelAwskinesisSinkConnector.properties | 33 --
.../CamelAwskinesisSourceConnector.properties | 33 --
.../awskinesis/CamelAwskinesisSinkConnector.java | 35 --
.../CamelAwskinesisSinkConnectorConfig.java | 128 -----
.../awskinesis/CamelAwskinesisSinkTask.java | 39 --
.../CamelAwskinesisSourceConnectorConfig.java | 240 ---------
.../awskinesis/CamelAwskinesisSourceTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-kms-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-kms-sink.json | 182 -------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-kms-kafka-sink-connector.adoc | 74 ---
.../awskms/CamelAwskmsSinkConnector.java | 35 --
.../awskms/CamelAwskmsSinkConnectorConfig.java | 134 -----
.../kafkaconnector/awskms/CamelAwskmsSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-lambda-sink.json | 208 -------
.../src/main/assembly/package.xml | 56 --
.../camel-aws-lambda-kafka-sink-connector.adoc | 74 ---
.../CamelAwslambdaSinkConnector.properties | 33 --
.../awslambda/CamelAwslambdaSinkConnector.java | 35 --
.../CamelAwslambdaSinkConnectorConfig.java | 136 -----
.../awslambda/CamelAwslambdaSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-mq-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../src/generated/resources/camel-aws-mq-sink.json | 182 -------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-mq-kafka-sink-connector.adoc | 74 ---
.../examples/CamelAwsmqSinkConnector.properties | 37 --
.../awsmq/CamelAwsmqSinkConnector.java | 35 --
.../awsmq/CamelAwsmqSinkConnectorConfig.java | 134 -----
.../kafkaconnector/awsmq/CamelAwsmqSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-msk-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-msk-sink.json | 178 ------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-msk-kafka-sink-connector.adoc | 74 ---
.../examples/CamelAwsmskSinkConnector.properties | 37 --
.../awsmsk/CamelAwsmskSinkConnector.java | 35 --
.../awsmsk/CamelAwsmskSinkConnectorConfig.java | 134 -----
.../kafkaconnector/awsmsk/CamelAwsmskSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-s3-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../descriptors/connector-source.properties | 1 -
.../src/generated/resources/camel-aws-s3-sink.json | 450 ----------------
.../generated/resources/camel-aws-s3-source.json | 566 -------------------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-s3-kafka-sink-connector.adoc | 128 -----
.../docs/camel-aws-s3-kafka-source-connector.adoc | 168 ------
.../awss3/CamelAwss3SinkConnector.java | 35 --
.../awss3/CamelAwss3SinkConnectorConfig.java | 294 ----------
.../kafkaconnector/awss3/CamelAwss3SinkTask.java | 39 --
.../awss3/CamelAwss3SourceConnector.java | 35 --
.../awss3/CamelAwss3SourceConnectorConfig.java | 360 -------------
.../kafkaconnector/awss3/CamelAwss3SourceTask.java | 39 --
.../awss3/converters/S3ObjectConverter.java | 45 --
.../awss3/serializers/S3ObjectSerializer.java | 59 --
.../awss3/transformers/S3ObjectTransforms.java | 55 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-sdb-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-sdb-sink.json | 118 ----
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-sdb-kafka-sink-connector.adoc | 65 ---
.../examples/CamelAwssdbSinkConnector.properties | 33 --
.../awssdb/CamelAwssdbSinkConnector.java | 35 --
.../awssdb/CamelAwssdbSinkConnectorConfig.java | 98 ----
.../kafkaconnector/awssdb/CamelAwssdbSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../pom.xml | 8 +-
.../descriptors/connector-sink.properties | 1 +
.../resources/camel-aws-secrets-manager-sink.json | 168 +++---
.../src/main/assembly/package.xml | 0
...l-aws-secrets-manager-kafka-sink-connector.adoc | 86 +++
...CamelAwssecretsmanagerSinkConnector.properties} | 10 +-
.../CamelAwssecretsmanagerSinkConnector.java} | 8 +-
.../CamelAwssecretsmanagerSinkConnectorConfig.java | 169 ++++++
.../CamelAwssecretsmanagerSinkTask.java} | 8 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
connectors/camel-aws-ses-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-ses-sink.json | 202 -------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-ses-kafka-sink-connector.adoc | 80 ---
.../examples/CamelAwssesSinkConnector.properties | 33 --
.../awsses/CamelAwssesSinkConnector.java | 35 --
.../awsses/CamelAwssesSinkConnectorConfig.java | 158 ------
.../kafkaconnector/awsses/CamelAwssesSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-sns-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../generated/resources/camel-aws-sns-sink.json | 274 ----------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-sns-kafka-sink-connector.adoc | 91 ----
.../examples/CamelAwssnsSinkConnector.properties | 33 --
.../awssns/CamelAwssnsSinkConnector.java | 35 --
.../awssns/CamelAwssnsSinkConnectorConfig.java | 202 -------
.../kafkaconnector/awssns/CamelAwssnsSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-sqs-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../descriptors/connector-source.properties | 1 -
.../generated/resources/camel-aws-sqs-sink.json | 378 -------------
.../generated/resources/camel-aws-sqs-source.json | 600 ---------------------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-sqs-kafka-sink-connector.adoc | 103 ----
.../docs/camel-aws-sqs-kafka-source-connector.adoc | 138 -----
.../examples/CamelAwssqsSinkConnector.properties | 33 --
.../examples/CamelAwssqsSourceConnector.properties | 33 --
.../awssqs/CamelAwssqsSinkConnector.java | 35 --
.../awssqs/CamelAwssqsSinkConnectorConfig.java | 250 ---------
.../kafkaconnector/awssqs/CamelAwssqsSinkTask.java | 39 --
.../awssqs/CamelAwssqsSourceConnector.java | 35 --
.../awssqs/CamelAwssqsSourceConnectorConfig.java | 392 --------------
.../awssqs/CamelAwssqsSourceTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
connectors/camel-aws-swf-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../descriptors/connector-source.properties | 1 -
.../generated/resources/camel-aws-swf-sink.json | 314 -----------
.../generated/resources/camel-aws-swf-source.json | 273 ----------
.../src/main/assembly/package.xml | 56 --
.../docs/camel-aws-swf-kafka-sink-connector.adoc | 96 ----
.../docs/camel-aws-swf-kafka-source-connector.adoc | 92 ----
.../examples/CamelAwsswfSinkConnector.properties | 33 --
.../examples/CamelAwsswfSourceConnector.properties | 33 --
.../awsswf/CamelAwsswfSinkConnector.java | 35 --
.../awsswf/CamelAwsswfSinkConnectorConfig.java | 222 --------
.../kafkaconnector/awsswf/CamelAwsswfSinkTask.java | 39 --
.../awsswf/CamelAwsswfSourceConnector.java | 35 --
.../awsswf/CamelAwsswfSourceConnectorConfig.java | 208 -------
.../awsswf/CamelAwsswfSourceTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../camel-aws-translate-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../resources/camel-aws-translate-sink.json | 212 --------
.../src/main/assembly/package.xml | 56 --
.../camel-aws-translate-kafka-sink-connector.adoc | 80 ---
.../CamelAwstranslateSinkConnector.properties | 37 --
.../CamelAwstranslateSinkConnector.java | 35 --
.../CamelAwstranslateSinkConnectorConfig.java | 160 ------
.../awstranslate/CamelAwstranslateSinkTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../generated/resources/camel-aws2-cw-sink.json | 26 +
.../docs/camel-aws2-cw-kafka-sink-connector.adoc | 6 +-
.../aws2cw/CamelAws2cwSinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-ddb-sink.json | 26 +
.../docs/camel-aws2-ddb-kafka-sink-connector.adoc | 6 +-
.../aws2ddb/CamelAws2ddbSinkConnectorConfig.java | 16 +
.../resources/camel-aws2-ddbstream-source.json | 26 +
...amel-aws2-ddbstream-kafka-source-connector.adoc | 6 +-
.../CamelAws2ddbstreamSourceConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-ec2-sink.json | 26 +
.../docs/camel-aws2-ec2-kafka-sink-connector.adoc | 6 +-
.../aws2ec2/CamelAws2ec2SinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-ecs-sink.json | 26 +
.../docs/camel-aws2-ecs-kafka-sink-connector.adoc | 6 +-
.../aws2ecs/CamelAws2ecsSinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-eks-sink.json | 26 +
.../docs/camel-aws2-eks-kafka-sink-connector.adoc | 6 +-
.../aws2eks/CamelAws2eksSinkConnectorConfig.java | 16 +
.../resources/camel-aws2-eventbridge-sink.json | 26 +
...amel-aws2-eventbridge-kafka-sink-connector.adoc | 6 +-
.../CamelAws2eventbridgeSinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-iam-sink.json | 26 +
.../docs/camel-aws2-iam-kafka-sink-connector.adoc | 6 +-
.../aws2iam/CamelAws2iamSinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-kms-sink.json | 26 +
.../docs/camel-aws2-kms-kafka-sink-connector.adoc | 6 +-
.../aws2kms/CamelAws2kmsSinkConnectorConfig.java | 16 +
.../resources/camel-aws2-lambda-sink.json | 26 +
.../camel-aws2-lambda-kafka-sink-connector.adoc | 6 +-
.../CamelAws2lambdaSinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-mq-sink.json | 26 +
.../docs/camel-aws2-mq-kafka-sink-connector.adoc | 6 +-
.../aws2mq/CamelAws2mqSinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-msk-sink.json | 26 +
.../docs/camel-aws2-msk-kafka-sink-connector.adoc | 6 +-
.../aws2msk/CamelAws2mskSinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-s3-sink.json | 4 +-
.../generated/resources/camel-aws2-s3-source.json | 4 +-
.../docs/camel-aws2-s3-kafka-sink-connector.adoc | 4 +-
.../docs/camel-aws2-s3-kafka-source-connector.adoc | 4 +-
.../aws2s3/CamelAws2s3SinkConnectorConfig.java | 4 +-
.../aws2s3/CamelAws2s3SourceConnectorConfig.java | 4 +-
.../generated/resources/camel-aws2-ses-sink.json | 26 +
.../docs/camel-aws2-ses-kafka-sink-connector.adoc | 6 +-
.../aws2ses/CamelAws2sesSinkConnectorConfig.java | 16 +
.../generated/resources/camel-aws2-sns-sink.json | 30 +-
.../docs/camel-aws2-sns-kafka-sink-connector.adoc | 10 +-
.../aws2sns/CamelAws2snsSinkConnectorConfig.java | 20 +-
.../generated/resources/camel-aws2-sqs-sink.json | 44 +-
.../generated/resources/camel-aws2-sqs-source.json | 34 +-
.../docs/camel-aws2-sqs-kafka-sink-connector.adoc | 12 +-
.../camel-aws2-sqs-kafka-source-connector.adoc | 14 +-
.../aws2sqs/CamelAws2sqsSinkConnectorConfig.java | 28 +-
.../aws2sqs/CamelAws2sqsSourceConnectorConfig.java | 24 +-
.../generated/resources/camel-aws2-sts-sink.json | 26 +
.../docs/camel-aws2-sts-kafka-sink-connector.adoc | 6 +-
.../aws2sts/CamelAws2stsSinkConnectorConfig.java | 16 +
.../resources/camel-aws2-translate-sink.json | 26 +
.../camel-aws2-translate-kafka-sink-connector.adoc | 6 +-
.../CamelAws2translateSinkConnectorConfig.java | 16 +
.../camel-azure-blob-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../descriptors/connector-source.properties | 1 -
.../generated/resources/camel-azure-blob-sink.json | 320 -----------
.../resources/camel-azure-blob-source.json | 227 --------
.../src/main/assembly/package.xml | 56 --
.../camel-azure-blob-kafka-sink-connector.adoc | 92 ----
.../camel-azure-blob-kafka-source-connector.adoc | 82 ---
.../CamelAzureblobSinkConnector.properties | 33 --
.../CamelAzureblobSourceConnector.properties | 33 --
.../azureblob/CamelAzureblobSinkConnector.java | 35 --
.../CamelAzureblobSinkConnectorConfig.java | 208 -------
.../azureblob/CamelAzureblobSinkTask.java | 39 --
.../azureblob/CamelAzureblobSourceConnector.java | 35 --
.../CamelAzureblobSourceConnectorConfig.java | 168 ------
.../azureblob/CamelAzureblobSourceTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../camel-azure-queue-kafka-connector/pom.xml | 139 -----
.../descriptors/connector-sink.properties | 1 -
.../descriptors/connector-source.properties | 1 -
.../resources/camel-azure-queue-sink.json | 178 ------
.../resources/camel-azure-queue-source.json | 125 -----
.../src/main/assembly/package.xml | 56 --
.../camel-azure-queue-kafka-sink-connector.adoc | 74 ---
.../camel-azure-queue-kafka-source-connector.adoc | 68 ---
.../CamelAzurequeueSinkConnector.properties | 33 --
.../CamelAzurequeueSourceConnector.properties | 33 --
.../azurequeue/CamelAzurequeueSinkConnector.java | 35 --
.../CamelAzurequeueSinkConnectorConfig.java | 136 -----
.../azurequeue/CamelAzurequeueSinkTask.java | 39 --
.../azurequeue/CamelAzurequeueSourceConnector.java | 35 --
.../CamelAzurequeueSourceConnectorConfig.java | 112 ----
.../azurequeue/CamelAzurequeueSourceTask.java | 39 --
.../src/main/resources/META-INF/LICENSE.txt | 203 -------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../src/generated/resources/camel-file-sink.json | 2 +-
.../main/docs/camel-file-kafka-sink-connector.adoc | 2 +-
.../file/CamelFileSinkConnectorConfig.java | 2 +-
.../generated/resources/camel-freemarker-sink.json | 7 +
.../camel-freemarker-kafka-sink-connector.adoc | 3 +-
.../CamelFreemarkerSinkConnectorConfig.java | 4 +
.../resources/camel-google-bigquery-sql-sink.json | 12 +-
...l-google-bigquery-sql-kafka-sink-connector.adoc | 2 +-
.../CamelGooglebigquerysqlSinkConnector.properties | 2 +-
.../CamelGooglebigquerysqlSinkConnectorConfig.java | 8 +-
.../pom.xml | 8 +-
.../descriptors/connector-sink.properties | 1 +
.../resources/camel-google-functions-sink.json | 92 ++--
.../src/main/assembly/package.xml | 0
...amel-google-functions-kafka-sink-connector.adoc | 65 +++
.../CamelGooglefunctionsSinkConnector.properties} | 8 +-
.../CamelGooglefunctionsSinkConnector.java} | 8 +-
.../CamelGooglefunctionsSinkConnectorConfig.java | 85 +++
.../CamelGooglefunctionsSinkTask.java} | 8 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../resources/camel-google-mail-stream-source.json | 4 +-
...-google-mail-stream-kafka-source-connector.adoc | 4 +-
...CamelGooglemailstreamSourceConnectorConfig.java | 4 +-
.../resources/camel-google-pubsub-sink.json | 16 +-
.../resources/camel-google-pubsub-source.json | 16 +-
.../camel-google-pubsub-kafka-sink-connector.adoc | 8 +-
...camel-google-pubsub-kafka-source-connector.adoc | 8 +-
.../CamelGooglepubsubSinkConnector.properties | 8 +-
.../CamelGooglepubsubSourceConnector.properties | 8 +-
.../CamelGooglepubsubSinkConnectorConfig.java | 12 +-
.../CamelGooglepubsubSourceConnectorConfig.java | 12 +-
.../pom.xml | 8 +-
.../descriptors/connector-sink.properties | 1 +
.../descriptors/connector-source.properties | 1 +
.../resources/camel-google-storage-sink.json | 154 ++++++
.../resources/camel-google-storage-source.json | 232 ++++----
.../src/main/assembly/package.xml | 0
.../camel-google-storage-kafka-sink-connector.adoc | 74 +++
...mel-google-storage-kafka-source-connector.adoc} | 74 +--
.../CamelGooglestorageSinkConnector.properties} | 6 +-
.../CamelGooglestorageSourceConnector.properties} | 6 +-
.../CamelGooglestorageSinkConnector.java} | 8 +-
.../CamelGooglestorageSinkConnectorConfig.java | 121 +++++
.../googlestorage/CamelGooglestorageSinkTask.java} | 8 +-
.../CamelGooglestorageSourceConnector.java} | 8 +-
.../CamelGooglestorageSourceConnectorConfig.java | 217 ++++++++
.../CamelGooglestorageSourceTask.java} | 8 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../src/generated/resources/camel-http-sink.json | 114 +++-
.../main/docs/camel-http-kafka-sink-connector.adoc | 20 +-
.../http/CamelHttpSinkConnectorConfig.java | 66 ++-
.../src/generated/resources/camel-https-sink.json | 114 +++-
.../docs/camel-https-kafka-sink-connector.adoc | 20 +-
.../https/CamelHttpsSinkConnectorConfig.java | 66 ++-
.../generated/resources/camel-jetty-source.json | 40 +-
.../docs/camel-jetty-kafka-source-connector.adoc | 6 +-
.../jetty/CamelJettySourceConnectorConfig.java | 24 +-
.../generated/resources/camel-kafka-source.json | 32 ++
.../docs/camel-kafka-kafka-source-connector.adoc | 5 +-
.../kafka/CamelKafkaSourceConnectorConfig.java | 12 +
.../generated/resources/camel-netty-http-sink.json | 14 +
.../resources/camel-netty-http-source.json | 14 +
.../camel-netty-http-kafka-sink-connector.adoc | 4 +-
.../camel-netty-http-kafka-source-connector.adoc | 4 +-
.../CamelNettyhttpSinkConnectorConfig.java | 8 +
.../CamelNettyhttpSourceConnectorConfig.java | 8 +
.../src/generated/resources/camel-netty-sink.json | 14 +
.../generated/resources/camel-netty-source.json | 14 +
.../docs/camel-netty-kafka-sink-connector.adoc | 4 +-
.../docs/camel-netty-kafka-source-connector.adoc | 4 +-
.../netty/CamelNettySinkConnectorConfig.java | 8 +
.../netty/CamelNettySourceConnectorConfig.java | 8 +
.../generated/resources/camel-resteasy-sink.json | 108 +++-
.../generated/resources/camel-resteasy-source.json | 89 ++-
.../docs/camel-resteasy-kafka-sink-connector.adoc | 20 +-
.../camel-resteasy-kafka-source-connector.adoc | 15 +-
.../resteasy/CamelResteasySinkConnectorConfig.java | 66 ++-
.../CamelResteasySourceConnectorConfig.java | 52 +-
.../generated/resources/camel-servlet-source.json | 28 +-
.../docs/camel-servlet-kafka-source-connector.adoc | 4 +-
.../servlet/CamelServletSourceConnectorConfig.java | 16 +-
.../src/generated/resources/camel-slack-sink.json | 12 +
.../generated/resources/camel-slack-source.json | 38 +-
.../docs/camel-slack-kafka-sink-connector.adoc | 4 +-
.../docs/camel-slack-kafka-source-connector.adoc | 7 +-
.../slack/CamelSlackSinkConnectorConfig.java | 8 +
.../slack/CamelSlackSourceConnectorConfig.java | 20 +-
.../src/generated/resources/camel-smpp-sink.json | 4 +-
.../src/generated/resources/camel-smpp-source.json | 4 +-
.../main/docs/camel-smpp-kafka-sink-connector.adoc | 4 +-
.../docs/camel-smpp-kafka-source-connector.adoc | 4 +-
.../smpp/CamelSmppSinkConnectorConfig.java | 4 +-
.../smpp/CamelSmppSourceConnectorConfig.java | 4 +-
.../src/generated/resources/camel-smpps-sink.json | 4 +-
.../generated/resources/camel-smpps-source.json | 4 +-
.../docs/camel-smpps-kafka-sink-connector.adoc | 4 +-
.../docs/camel-smpps-kafka-source-connector.adoc | 4 +-
.../smpps/CamelSmppsSinkConnectorConfig.java | 4 +-
.../smpps/CamelSmppsSourceConnectorConfig.java | 4 +-
.../src/generated/resources/camel-splunk-sink.json | 6 +
.../docs/camel-splunk-kafka-sink-connector.adoc | 3 +-
.../splunk/CamelSplunkSinkConnectorConfig.java | 4 +
.../resources/camel-spring-rabbitmq-sink.json | 14 +
.../resources/camel-spring-rabbitmq-source.json | 107 ++++
...camel-spring-rabbitmq-kafka-sink-connector.adoc | 4 +-
...mel-spring-rabbitmq-kafka-source-connector.adoc | 17 +-
.../CamelSpringrabbitmqSinkConnectorConfig.java | 8 +
.../CamelSpringrabbitmqSourceConnectorConfig.java | 60 +++
.../generated/resources/camel-vertx-http-sink.json | 14 +
.../camel-vertx-http-kafka-sink-connector.adoc | 4 +-
.../CamelVertxhttpSinkConnectorConfig.java | 8 +
.../resources/camel-vertx-kafka-source.json | 20 +
.../camel-vertx-kafka-kafka-source-connector.adoc | 5 +-
.../CamelVertxkafkaSourceConnectorConfig.java | 12 +
connectors/pom.xml | 25 +-
docs/modules/ROOT/nav.adoc | 57 +-
docs/modules/ROOT/pages/connectors.adoc | 27 +-
...-atmosphere-websocket-kafka-sink-connector.adoc | 5 +-
...tmosphere-websocket-kafka-source-connector.adoc | 4 +-
...l-aws-secrets-manager-kafka-sink-connector.adoc | 86 +++
.../camel-aws2-cw-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-ddb-kafka-sink-connector.adoc | 6 +-
...amel-aws2-ddbstream-kafka-source-connector.adoc | 6 +-
.../camel-aws2-ec2-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-ecs-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-eks-kafka-sink-connector.adoc | 6 +-
...amel-aws2-eventbridge-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-iam-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-kms-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-lambda-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-mq-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-msk-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-s3-kafka-sink-connector.adoc | 4 +-
.../camel-aws2-s3-kafka-source-connector.adoc | 4 +-
.../camel-aws2-ses-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-sns-kafka-sink-connector.adoc | 10 +-
.../camel-aws2-sqs-kafka-sink-connector.adoc | 12 +-
.../camel-aws2-sqs-kafka-source-connector.adoc | 14 +-
.../camel-aws2-sts-kafka-sink-connector.adoc | 6 +-
.../camel-aws2-translate-kafka-sink-connector.adoc | 6 +-
.../camel-file-kafka-sink-connector.adoc | 2 +-
.../camel-freemarker-kafka-sink-connector.adoc | 3 +-
...l-google-bigquery-sql-kafka-sink-connector.adoc | 2 +-
...amel-google-functions-kafka-sink-connector.adoc | 65 +++
...-google-mail-stream-kafka-source-connector.adoc | 4 +-
.../camel-google-pubsub-kafka-sink-connector.adoc | 8 +-
...camel-google-pubsub-kafka-source-connector.adoc | 8 +-
.../camel-google-storage-kafka-sink-connector.adoc | 74 +++
...amel-google-storage-kafka-source-connector.adoc | 74 +--
.../camel-http-kafka-sink-connector.adoc | 20 +-
.../camel-https-kafka-sink-connector.adoc | 20 +-
.../camel-jetty-kafka-source-connector.adoc | 6 +-
.../camel-kafka-kafka-source-connector.adoc | 5 +-
.../camel-netty-http-kafka-sink-connector.adoc | 4 +-
.../camel-netty-http-kafka-source-connector.adoc | 4 +-
.../camel-netty-kafka-sink-connector.adoc | 4 +-
.../camel-netty-kafka-source-connector.adoc | 4 +-
.../camel-resteasy-kafka-sink-connector.adoc | 20 +-
.../camel-resteasy-kafka-source-connector.adoc | 15 +-
.../camel-servlet-kafka-source-connector.adoc | 4 +-
.../camel-slack-kafka-sink-connector.adoc | 4 +-
.../camel-slack-kafka-source-connector.adoc | 7 +-
.../camel-smpp-kafka-sink-connector.adoc | 4 +-
.../camel-smpp-kafka-source-connector.adoc | 4 +-
.../camel-smpps-kafka-sink-connector.adoc | 4 +-
.../camel-smpps-kafka-source-connector.adoc | 4 +-
.../camel-splunk-kafka-sink-connector.adoc | 3 +-
...camel-spring-rabbitmq-kafka-sink-connector.adoc | 4 +-
...mel-spring-rabbitmq-kafka-source-connector.adoc | 17 +-
.../camel-vertx-http-kafka-sink-connector.adoc | 4 +-
.../camel-vertx-kafka-kafka-source-connector.adoc | 5 +-
parent/pom.xml | 2 +-
pom.xml | 2 +-
tests/itests-aws-v1/pom.xml | 92 ----
.../aws/v1/clients/AWSSQSClient.java | 125 -----
.../source/CamelAWSKinesisPropertyFactory.java | 84 ---
.../source/CamelSourceAWSKinesisITCase.java | 260 ---------
.../kinesis/source/TestKinesisConfiguration.java | 39 --
.../v1/s3/source/CamelAWSS3PropertyFactory.java | 88 ---
.../aws/v1/s3/source/CamelSourceAWSS3ITCase.java | 230 --------
.../aws/v1/s3/source/TestS3Configuration.java | 39 --
.../v1/sns/sink/CamelAWSSNSPropertyFactory.java | 88 ---
.../aws/v1/sns/sink/CamelSinkAWSSNSITCase.java | 167 ------
.../aws/v1/sns/sink/TestSNSConfiguration.java | 36 --
.../v1/sqs/sink/CamelAWSSQSPropertyFactory.java | 103 ----
.../aws/v1/sqs/sink/CamelSinkAWSSQSITCase.java | 179 ------
.../v1/sqs/source/CamelAWSSQSPropertyFactory.java | 98 ----
.../aws/v1/sqs/source/CamelSourceAWSSQSITCase.java | 157 ------
.../kafkaconnector/aws/v1/s3/source/file0.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file1.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file2.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file3.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file4.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file5.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file6.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file7.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file8.test | 14 -
.../kafkaconnector/aws/v1/s3/source/file9.test | 14 -
.../blob/sink/CamelSinkAzureStorageBlobITCase.java | 2 +-
.../sink/CamelSinkAzureStorageQueueITCase.java | 2 +-
.../source/CamelSourceAzureStorageQueueITCase.java | 2 +-
.../kafkaconnector/common/AbstractKafkaTest.java | 15 +-
.../common/services/kafka/KafkaServiceFactory.java | 45 --
.../common/services/kafka/StrimziService.java | 103 ----
.../kafkaconnector/sjms2/common/SJMS2Common.java | 9 +
.../sjms2/sink/CamelSinkIdempotentJMSITCase.java | 9 +-
.../sjms2/sink/CamelSinkJMSITCase.java | 9 +-
.../sjms2/source/CamelSourceJMSITCase.java | 9 +-
.../source/CamelSourceJMSWithAggregation.java | 9 +-
tests/pom.xml | 1 -
616 files changed, 5734 insertions(+), 29333 deletions(-)
copy
camel-kafka-connector-catalog/src/generated/resources/connectors/{camel-aws2-translate-sink.json
=> camel-aws-secrets-manager-sink.json} (54%)
copy
camel-kafka-connector-catalog/src/generated/resources/connectors/{camel-slack-sink.json
=> camel-google-functions-sink.json} (51%)
create mode 100644
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-storage-sink.json
rename
connectors/camel-aws-ddbstream-kafka-connector/src/generated/resources/camel-aws-ddbstream-source.json
=>
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-storage-source.json
(58%)
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/generated/resources/camel-aws-cw-sink.json
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/main/docs/camel-aws-cw-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/main/docs/examples/CamelAwscwSinkConnector.properties
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awscw/CamelAwscwSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awscw/CamelAwscwSinkTask.java
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-cw-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-ddb-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-ddb-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-ddb-kafka-connector/src/generated/resources/camel-aws-ddb-sink.json
delete mode 100644
connectors/camel-aws-ddb-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-ddb-kafka-connector/src/main/docs/camel-aws-ddb-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-ddb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddb/CamelAwsddbSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-ddb-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-ddb-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-ddbstream-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-ddbstream-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-aws-ddbstream-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-ddbstream-kafka-connector/src/main/docs/camel-aws-ddbstream-kafka-source-connector.adoc
delete mode 100644
connectors/camel-aws-ddbstream-kafka-connector/src/main/docs/examples/CamelAwsddbstreamSourceConnector.properties
delete mode 100644
connectors/camel-aws-ddbstream-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddbstream/CamelAwsddbstreamSourceConnector.java
delete mode 100644
connectors/camel-aws-ddbstream-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddbstream/CamelAwsddbstreamSourceConnectorConfig.java
delete mode 100644
connectors/camel-aws-ddbstream-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-ddbstream-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/generated/resources/camel-aws-ec2-sink.json
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/main/docs/camel-aws-ec2-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/main/docs/examples/CamelAwsec2SinkConnector.properties
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsec2/CamelAwsec2SinkConnector.java
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsec2/CamelAwsec2SinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-ec2-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-ecs-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-ecs-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-ecs-kafka-connector/src/generated/resources/camel-aws-ecs-sink.json
delete mode 100644
connectors/camel-aws-ecs-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-ecs-kafka-connector/src/main/docs/camel-aws-ecs-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-ecs-kafka-connector/src/main/docs/examples/CamelAwsecsSinkConnector.properties
delete mode 100644
connectors/camel-aws-ecs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsecs/CamelAwsecsSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-ecs-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-ecs-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-eks-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/generated/resources/camel-aws-eks-sink.json
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/main/docs/camel-aws-eks-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/main/docs/examples/CamelAwseksSinkConnector.properties
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awseks/CamelAwseksSinkConnector.java
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awseks/CamelAwseksSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awseks/CamelAwseksSinkTask.java
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-eks-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-iam-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/generated/resources/camel-aws-iam-sink.json
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/main/docs/camel-aws-iam-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/main/docs/examples/CamelAwsiamSinkConnector.properties
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsiam/CamelAwsiamSinkConnector.java
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsiam/CamelAwsiamSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsiam/CamelAwsiamSinkTask.java
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-iam-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/generated/resources/camel-aws-kinesis-firehose-sink.json
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/main/docs/camel-aws-kinesis-firehose-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/main/docs/examples/CamelAwskinesisfirehoseSinkConnector.properties
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesisfirehose/CamelAwskinesisfirehoseSinkConnector.java
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesisfirehose/CamelAwskinesisfirehoseSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesisfirehose/CamelAwskinesisfirehoseSinkTask.java
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-kinesis-firehose-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-kinesis-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/generated/resources/camel-aws-kinesis-sink.json
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/generated/resources/camel-aws-kinesis-source.json
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/docs/camel-aws-kinesis-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/docs/camel-aws-kinesis-kafka-source-connector.adoc
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/docs/examples/CamelAwskinesisSinkConnector.properties
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/docs/examples/CamelAwskinesisSourceConnector.properties
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesis/CamelAwskinesisSinkConnector.java
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesis/CamelAwskinesisSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesis/CamelAwskinesisSinkTask.java
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesis/CamelAwskinesisSourceConnectorConfig.java
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesis/CamelAwskinesisSourceTask.java
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-kinesis-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-kms-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/generated/resources/camel-aws-kms-sink.json
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/main/docs/camel-aws-kms-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskms/CamelAwskmsSinkConnector.java
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskms/CamelAwskmsSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskms/CamelAwskmsSinkTask.java
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-kms-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/generated/resources/camel-aws-lambda-sink.json
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/main/docs/camel-aws-lambda-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/main/docs/examples/CamelAwslambdaSinkConnector.properties
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awslambda/CamelAwslambdaSinkConnector.java
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awslambda/CamelAwslambdaSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awslambda/CamelAwslambdaSinkTask.java
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-lambda-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-mq-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/generated/resources/camel-aws-mq-sink.json
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/main/docs/camel-aws-mq-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/main/docs/examples/CamelAwsmqSinkConnector.properties
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsmq/CamelAwsmqSinkConnector.java
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsmq/CamelAwsmqSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsmq/CamelAwsmqSinkTask.java
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-mq-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-msk-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/generated/resources/camel-aws-msk-sink.json
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/main/docs/camel-aws-msk-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/main/docs/examples/CamelAwsmskSinkConnector.properties
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsmsk/CamelAwsmskSinkConnector.java
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsmsk/CamelAwsmskSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsmsk/CamelAwsmskSinkTask.java
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-msk-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-s3-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/CamelAwss3SinkConnector.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/CamelAwss3SinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/CamelAwss3SinkTask.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/CamelAwss3SourceConnector.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/CamelAwss3SourceConnectorConfig.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/CamelAwss3SourceTask.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/converters/S3ObjectConverter.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/serializers/S3ObjectSerializer.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransforms.java
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-s3-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-sdb-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/generated/resources/camel-aws-sdb-sink.json
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/main/docs/camel-aws-sdb-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/main/docs/examples/CamelAwssdbSinkConnector.properties
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssdb/CamelAwssdbSinkConnector.java
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssdb/CamelAwssdbSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssdb/CamelAwssdbSinkTask.java
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-sdb-kafka-connector/src/main/resources/META-INF/NOTICE.txt
rename connectors/{camel-aws-ec2-kafka-connector =>
camel-aws-secrets-manager-kafka-connector}/pom.xml (94%)
create mode 100644
connectors/camel-aws-secrets-manager-kafka-connector/src/generated/descriptors/connector-sink.properties
copy
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-translate-sink.json
=>
connectors/camel-aws-secrets-manager-kafka-connector/src/generated/resources/camel-aws-secrets-manager-sink.json
(54%)
copy connectors/{camel-zookeeper-master-kafka-connector =>
camel-aws-secrets-manager-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644
connectors/camel-aws-secrets-manager-kafka-connector/src/main/docs/camel-aws-secrets-manager-kafka-sink-connector.adoc
rename
connectors/{camel-aws-kms-kafka-connector/src/main/docs/examples/CamelAwskmsSinkConnector.properties
=>
camel-aws-secrets-manager-kafka-connector/src/main/docs/examples/CamelAwssecretsmanagerSinkConnector.properties}
(74%)
rename
connectors/{camel-aws-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awscw/CamelAwscwSinkConnector.java
=>
camel-aws-secrets-manager-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssecretsmanager/CamelAwssecretsmanagerSinkConnector.java}
(83%)
create mode 100644
connectors/camel-aws-secrets-manager-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssecretsmanager/CamelAwssecretsmanagerSinkConnectorConfig.java
rename
connectors/{camel-aws-ec2-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsec2/CamelAwsec2SinkTask.java
=>
camel-aws-secrets-manager-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssecretsmanager/CamelAwssecretsmanagerSinkTask.java}
(86%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-aws-secrets-manager-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-aws-secrets-manager-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
delete mode 100644 connectors/camel-aws-ses-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/generated/resources/camel-aws-ses-sink.json
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/main/docs/camel-aws-ses-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/main/docs/examples/CamelAwssesSinkConnector.properties
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsses/CamelAwssesSinkConnector.java
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsses/CamelAwssesSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsses/CamelAwssesSinkTask.java
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-ses-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-sns-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/generated/resources/camel-aws-sns-sink.json
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/main/docs/camel-aws-sns-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/main/docs/examples/CamelAwssnsSinkConnector.properties
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssns/CamelAwssnsSinkConnector.java
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssns/CamelAwssnsSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssns/CamelAwssnsSinkTask.java
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-sns-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-sqs-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/generated/resources/camel-aws-sqs-sink.json
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/generated/resources/camel-aws-sqs-source.json
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/docs/camel-aws-sqs-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/docs/camel-aws-sqs-kafka-source-connector.adoc
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/docs/examples/CamelAwssqsSinkConnector.properties
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/docs/examples/CamelAwssqsSourceConnector.properties
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssqs/CamelAwssqsSinkConnector.java
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssqs/CamelAwssqsSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssqs/CamelAwssqsSinkTask.java
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssqs/CamelAwssqsSourceConnector.java
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssqs/CamelAwssqsSourceConnectorConfig.java
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awssqs/CamelAwssqsSourceTask.java
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-sqs-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-swf-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/generated/resources/camel-aws-swf-sink.json
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/generated/resources/camel-aws-swf-source.json
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/docs/camel-aws-swf-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/docs/camel-aws-swf-kafka-source-connector.adoc
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/docs/examples/CamelAwsswfSinkConnector.properties
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/docs/examples/CamelAwsswfSourceConnector.properties
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsswf/CamelAwsswfSinkConnector.java
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsswf/CamelAwsswfSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsswf/CamelAwsswfSinkTask.java
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsswf/CamelAwsswfSourceConnector.java
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsswf/CamelAwsswfSourceConnectorConfig.java
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsswf/CamelAwsswfSourceTask.java
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-swf-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-aws-translate-kafka-connector/pom.xml
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/generated/resources/camel-aws-translate-sink.json
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/main/docs/camel-aws-translate-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/main/docs/examples/CamelAwstranslateSinkConnector.properties
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awstranslate/CamelAwstranslateSinkConnector.java
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awstranslate/CamelAwstranslateSinkConnectorConfig.java
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awstranslate/CamelAwstranslateSinkTask.java
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-aws-translate-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-azure-blob-kafka-connector/pom.xml
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/generated/resources/camel-azure-blob-sink.json
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/generated/resources/camel-azure-blob-source.json
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/docs/camel-azure-blob-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/docs/camel-azure-blob-kafka-source-connector.adoc
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/docs/examples/CamelAzureblobSinkConnector.properties
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/docs/examples/CamelAzureblobSourceConnector.properties
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureblob/CamelAzureblobSinkConnector.java
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureblob/CamelAzureblobSinkConnectorConfig.java
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureblob/CamelAzureblobSinkTask.java
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureblob/CamelAzureblobSourceConnector.java
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureblob/CamelAzureblobSourceConnectorConfig.java
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureblob/CamelAzureblobSourceTask.java
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-azure-blob-kafka-connector/src/main/resources/META-INF/NOTICE.txt
delete mode 100644 connectors/camel-azure-queue-kafka-connector/pom.xml
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/generated/descriptors/connector-sink.properties
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/generated/descriptors/connector-source.properties
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/generated/resources/camel-azure-queue-sink.json
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/generated/resources/camel-azure-queue-source.json
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/assembly/package.xml
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/docs/camel-azure-queue-kafka-sink-connector.adoc
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/docs/camel-azure-queue-kafka-source-connector.adoc
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/docs/examples/CamelAzurequeueSinkConnector.properties
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/docs/examples/CamelAzurequeueSourceConnector.properties
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurequeue/CamelAzurequeueSinkConnector.java
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurequeue/CamelAzurequeueSinkConnectorConfig.java
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurequeue/CamelAzurequeueSinkTask.java
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurequeue/CamelAzurequeueSourceConnector.java
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurequeue/CamelAzurequeueSourceConnectorConfig.java
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurequeue/CamelAzurequeueSourceTask.java
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/resources/META-INF/LICENSE.txt
delete mode 100644
connectors/camel-azure-queue-kafka-connector/src/main/resources/META-INF/NOTICE.txt
rename connectors/{camel-aws-lambda-kafka-connector =>
camel-google-functions-kafka-connector}/pom.xml (94%)
create mode 100644
connectors/camel-google-functions-kafka-connector/src/generated/descriptors/connector-sink.properties
copy
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-slack-sink.json
=>
connectors/camel-google-functions-kafka-connector/src/generated/resources/camel-google-functions-sink.json
(51%)
copy connectors/{camel-zookeeper-master-kafka-connector =>
camel-google-functions-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644
connectors/camel-google-functions-kafka-connector/src/main/docs/camel-google-functions-kafka-sink-connector.adoc
rename
connectors/{camel-aws-ddb-kafka-connector/src/main/docs/examples/CamelAwsddbSinkConnector.properties
=>
camel-google-functions-kafka-connector/src/main/docs/examples/CamelGooglefunctionsSinkConnector.properties}
(86%)
rename
connectors/{camel-aws-ecs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsecs/CamelAwsecsSinkConnector.java
=>
camel-google-functions-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlefunctions/CamelGooglefunctionsSinkConnector.java}
(83%)
create mode 100644
connectors/camel-google-functions-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlefunctions/CamelGooglefunctionsSinkConnectorConfig.java
rename
connectors/{camel-aws-ddb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddb/CamelAwsddbSinkTask.java
=>
camel-google-functions-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlefunctions/CamelGooglefunctionsSinkTask.java}
(87%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-google-functions-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-google-functions-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
rename connectors/{camel-aws-cw-kafka-connector =>
camel-google-storage-kafka-connector}/pom.xml (94%)
create mode 100644
connectors/camel-google-storage-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644
connectors/camel-google-storage-kafka-connector/src/generated/descriptors/connector-source.properties
create mode 100644
connectors/camel-google-storage-kafka-connector/src/generated/resources/camel-google-storage-sink.json
copy
camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-ddbstream-source.json
=>
connectors/camel-google-storage-kafka-connector/src/generated/resources/camel-google-storage-source.json
(58%)
copy connectors/{camel-zookeeper-master-kafka-connector =>
camel-google-storage-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644
connectors/camel-google-storage-kafka-connector/src/main/docs/camel-google-storage-kafka-sink-connector.adoc
copy
connectors/{camel-aws2-ddbstream-kafka-connector/src/main/docs/camel-aws2-ddbstream-kafka-source-connector.adoc
=>
camel-google-storage-kafka-connector/src/main/docs/camel-google-storage-kafka-source-connector.adoc}
(52%)
rename
connectors/{camel-aws-s3-kafka-connector/src/main/docs/examples/CamelAwss3SinkConnector.properties
=>
camel-google-storage-kafka-connector/src/main/docs/examples/CamelGooglestorageSinkConnector.properties}
(89%)
rename
connectors/{camel-aws-s3-kafka-connector/src/main/docs/examples/CamelAwss3SourceConnector.properties
=>
camel-google-storage-kafka-connector/src/main/docs/examples/CamelGooglestorageSourceConnector.properties}
(89%)
rename
connectors/{camel-aws-ddb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddb/CamelAwsddbSinkConnector.java
=>
camel-google-storage-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorage/CamelGooglestorageSinkConnector.java}
(84%)
create mode 100644
connectors/camel-google-storage-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorage/CamelGooglestorageSinkConnectorConfig.java
rename
connectors/{camel-aws-ecs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsecs/CamelAwsecsSinkTask.java
=>
camel-google-storage-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorage/CamelGooglestorageSinkTask.java}
(87%)
rename
connectors/{camel-aws-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awskinesis/CamelAwskinesisSourceConnector.java
=>
camel-google-storage-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorage/CamelGooglestorageSourceConnector.java}
(83%)
create mode 100644
connectors/camel-google-storage-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorage/CamelGooglestorageSourceConnectorConfig.java
rename
connectors/{camel-aws-ddbstream-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsddbstream/CamelAwsddbstreamSourceTask.java
=>
camel-google-storage-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorage/CamelGooglestorageSourceTask.java}
(87%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-google-storage-kafka-connector}/src/main/resources/META-INF/LICENSE.txt
(100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin =>
connectors/camel-google-storage-kafka-connector}/src/main/resources/META-INF/NOTICE.txt
(100%)
create mode 100644
docs/modules/ROOT/pages/connectors/camel-aws-secrets-manager-kafka-sink-connector.adoc
create mode 100644
docs/modules/ROOT/pages/connectors/camel-google-functions-kafka-sink-connector.adoc
create mode 100644
docs/modules/ROOT/pages/connectors/camel-google-storage-kafka-sink-connector.adoc
copy
connectors/camel-aws2-ddbstream-kafka-connector/src/main/docs/camel-aws2-ddbstream-kafka-source-connector.adoc
=>
docs/modules/ROOT/pages/connectors/camel-google-storage-kafka-source-connector.adoc
(52%)
delete mode 100644 tests/itests-aws-v1/pom.xml
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/clients/AWSSQSClient.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/kinesis/source/CamelAWSKinesisPropertyFactory.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/kinesis/source/CamelSourceAWSKinesisITCase.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/kinesis/source/TestKinesisConfiguration.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/s3/source/CamelAWSS3PropertyFactory.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/s3/source/CamelSourceAWSS3ITCase.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/s3/source/TestS3Configuration.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/sns/sink/CamelAWSSNSPropertyFactory.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/sns/sink/CamelSinkAWSSNSITCase.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/sns/sink/TestSNSConfiguration.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/sqs/sink/CamelAWSSQSPropertyFactory.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/sqs/sink/CamelSinkAWSSQSITCase.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/sqs/source/CamelAWSSQSPropertyFactory.java
delete mode 100644
tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/sqs/source/CamelSourceAWSSQSITCase.java
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file0.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file1.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file2.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file3.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file4.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file5.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file6.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file7.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file8.test
delete mode 100644
tests/itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1/s3/source/file9.test
delete mode 100644
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/KafkaServiceFactory.java
delete mode 100644
tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/StrimziService.java
