This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch automatic-periodic-sync in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
from 40e0c9acbe Updated CHANGELOG.md add 89a1b5a40e Updated to camel 4.8.0 No new revisions were added by this update. Summary of changes: .../pom.xml | 2 +- .../pom.xml | 2 +- .../pom.xml | 2 +- archetypes/pom.xml | 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- .../camel-aws-bedrock-agent-runtime-sink-sink.json | 89 +++++++++ .../camel-aws-bedrock-text-sink-sink.json | 83 +++++++++ .../camel-aws-cloudtrail-source-source.json | 28 ++- .../connectors/camel-aws-cloudwatch-sink-sink.json | 30 ++- .../connectors/camel-aws-ddb-sink-sink.json | 28 ++- .../camel-aws-ddb-streams-source-source.json | 28 ++- .../connectors/camel-aws-ec2-sink-sink.json | 30 ++- .../camel-aws-eventbridge-sink-sink.json | 28 ++- .../camel-aws-kinesis-firehose-sink-sink.json | 28 ++- .../connectors/camel-aws-kinesis-sink-sink.json | 28 ++- .../camel-aws-kinesis-source-source.json | 42 ++++- .../connectors/camel-aws-lambda-sink-sink.json | 28 ++- .../connectors/camel-aws-redshift-sink-sink.json | 2 +- .../camel-aws-redshift-source-source.json | 2 +- .../camel-aws-s3-event-based-source-source.json | 66 +++---- .../connectors/camel-aws-s3-sink-sink.json | 28 ++- .../connectors/camel-aws-s3-source-source.json | 53 +++++- .../camel-aws-s3-streaming-upload-sink-sink.json | 28 ++- .../camel-aws-secrets-manager-sink-sink.json | 28 ++- .../connectors/camel-aws-ses-sink-sink.json | 28 ++- .../connectors/camel-aws-sns-fifo-sink-sink.json | 28 ++- .../connectors/camel-aws-sns-sink-sink.json | 28 ++- .../connectors/camel-aws-sqs-batch-sink-sink.json | 28 ++- .../connectors/camel-aws-sqs-fifo-sink-sink.json | 28 ++- .../connectors/camel-aws-sqs-sink-sink.json | 28 ++- .../connectors/camel-aws-sqs-source-source.json | 47 ++++- .../camel-aws-timestream-query-sink-sink.json | 28 ++- .../resources/connectors/camel-aws2-iam-sink.json | 2 +- .../resources/connectors/camel-aws2-kms-sink.json | 10 +- .../connectors/camel-azure-cosmosdb-sink-sink.json | 2 +- .../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 | 2 +- .../camel-azure-storage-blob-append-sink-sink.json | 2 +- ...zure-storage-blob-changefeed-source-source.json | 2 +- ...ure-storage-blob-event-based-source-source.json | 46 ++--- .../camel-azure-storage-blob-sink-sink.json | 2 +- .../camel-azure-storage-blob-source-source.json | 2 +- .../camel-azure-storage-datalake-sink-sink.json | 2 +- ...camel-azure-storage-datalake-source-source.json | 2 +- .../camel-azure-storage-files-sink-sink.json | 2 +- .../camel-azure-storage-files-source-source.json | 2 +- .../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 | 9 +- .../connectors/camel-cassandra-source-source.json | 2 +- .../resources/connectors/camel-ceph-sink-sink.json | 2 +- .../connectors/camel-ceph-source-source.json | 2 +- .../camel-chuck-norris-source-source.json | 2 +- .../connectors/camel-coffee-source-source.json | 2 +- .../connectors/camel-couchbase-sink-sink.json | 2 +- .../connectors/camel-counter-source-source.json | 33 ++++ .../connectors/camel-cron-source-source.json | 2 +- .../resources/connectors/camel-cxf-sink.json | 2 +- .../resources/connectors/camel-cxf-source.json | 2 +- .../resources/connectors/camel-cxfrs-sink.json | 2 +- .../resources/connectors/camel-cxfrs-source.json | 2 +- .../connectors/camel-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 | 2 +- .../camel-elasticsearch-search-source-source.json | 2 +- .../resources/connectors/camel-exec-sink-sink.json | 2 +- .../resources/connectors/camel-fhir-sink-sink.json | 2 +- .../connectors/camel-fhir-source-source.json | 2 +- .../resources/connectors/camel-file-sink.json | 12 +- .../resources/connectors/camel-file-source.json | 19 +- .../connectors/camel-file-watch-source-source.json | 2 +- .../resources/connectors/camel-ftp-sink-sink.json | 2 +- .../connectors/camel-ftp-source-source.json | 2 +- .../resources/connectors/camel-ftps-sink-sink.json | 2 +- .../connectors/camel-ftps-source-source.json | 2 +- .../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 +- .../connectors/camel-google-sheets-sink-sink.json | 2 +- .../camel-google-sheets-source-source.json | 2 +- ...l-google-storage-event-based-source-source.json | 42 ++--- .../connectors/camel-google-storage-sink-sink.json | 2 +- .../camel-google-storage-source-source.json | 2 +- .../connectors/camel-graphql-sink-sink.json | 2 +- .../connectors/camel-http-secured-sink-sink.json | 29 ++- .../camel-http-secured-source-source.json | 29 ++- .../resources/connectors/camel-http-sink-sink.json | 2 +- .../connectors/camel-http-source-source.json | 2 +- .../resources/connectors/camel-https-sink.json | 94 +++++----- .../connectors/camel-infinispan-sink-sink.json | 2 +- .../connectors/camel-infinispan-source-source.json | 2 +- .../resources/connectors/camel-jdbc-sink.json | 2 +- .../connectors/camel-jms-amqp-10-sink-sink.json | 2 +- .../camel-jms-amqp-10-source-source.json | 2 +- .../camel-jms-apache-artemis-sink-sink.json | 2 +- .../camel-jms-apache-artemis-source-source.json | 4 +- .../connectors/camel-jms-ibm-mq-sink-sink.json | 2 +- .../connectors/camel-jms-ibm-mq-source-source.json | 2 +- .../camel-jms-pooled-apache-artemis-sink-sink.json | 65 +++++++ ...el-jms-pooled-apache-artemis-source-source.json | 65 +++++++ ...ka-apicurio-registry-not-secured-sink-sink.json | 4 +- ...picurio-registry-not-secured-source-source.json | 11 +- ...amel-kafka-azure-schema-registry-sink-sink.json | 2 +- ...-kafka-azure-schema-registry-source-source.json | 2 +- ...picurio-registry-not-secured-source-source.json | 9 +- ...afka-batch-apicurio-registry-source-source.json | 149 +++++++++++++++ ...-batch-azure-schema-registry-source-source.json | 9 +- ...amel-kafka-batch-not-secured-source-source.json | 9 +- .../camel-kafka-batch-scram-source-source.json | 9 +- .../camel-kafka-batch-source-source.json | 9 +- .../camel-kafka-batch-ssl-source-source.json | 9 +- ...cured-apicurio-registry-json-source-source.json | 122 +++++++++++++ ...ka-not-secured-apicurio-registry-sink-sink.json | 81 ++++++++ ...ot-secured-apicurio-registry-source-source.json | 129 +++++++++++++ .../camel-kafka-not-secured-sink-sink.json | 4 +- .../camel-kafka-not-secured-source-source.json | 2 +- .../connectors/camel-kafka-scram-sink-sink.json | 2 +- .../camel-kafka-scram-source-source.json | 2 +- .../connectors/camel-kafka-sink-sink.json | 2 +- .../connectors/camel-kafka-source-source.json | 2 +- .../connectors/camel-kafka-ssl-sink-sink.json | 2 +- .../connectors/camel-kafka-ssl-source-source.json | 2 +- .../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 | 2 +- .../connectors/camel-mongodb-sink-sink.json | 2 +- .../connectors/camel-mongodb-source-source.json | 2 +- .../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 | 2 +- .../connectors/camel-netty-http-source.json | 2 +- .../resources/connectors/camel-netty-sink.json | 2 +- .../resources/connectors/camel-netty-source.json | 2 +- .../camel-opensearch-index-sink-sink.json | 2 +- .../camel-opensearch-search-source-source.json | 2 +- .../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 | 2 +- .../connectors/camel-pulsar-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 +- ...amel-salesforce-composite-upsert-sink-sink.json | 2 +- .../camel-salesforce-create-sink-sink.json | 2 +- .../camel-salesforce-delete-sink-sink.json | 2 +- .../connectors/camel-salesforce-source-source.json | 8 +- .../camel-salesforce-update-sink-sink.json | 4 +- .../resources/connectors/camel-scp-sink-sink.json | 2 +- .../resources/connectors/camel-sftp-sink-sink.json | 2 +- .../connectors/camel-sftp-source-source.json | 2 +- .../resources/connectors/camel-sjms2-sink.json | 2 +- .../resources/connectors/camel-sjms2-source.json | 2 +- .../connectors/camel-slack-sink-sink.json | 2 +- .../connectors/camel-slack-source-source.json | 11 +- .../connectors/camel-snowflake-sink-sink.json | 2 +- .../connectors/camel-snowflake-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 +- .../camel-spring-rabbitmq-sink-sink.json | 16 +- .../camel-spring-rabbitmq-source-source.json | 9 +- .../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 | 2 +- .../connectors/camel-telegram-source-source.json | 2 +- .../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-wttrin-source-source.json | 2 +- .../resources/descriptors/connectors.properties | 16 +- .../pom.xml | 14 +- .../descriptors/connector-sink.properties | 1 + .../camel-aws-bedrock-agent-runtime-sink-sink.json | 89 +++++++++ .../src/main/assembly/package.xml | 0 ...edrockagentruntimesinkSinkConnector.properties} | 18 +- ...elAwsbedrockagentruntimesinkSinkConnector.java} | 12 +- ...bedrockagentruntimesinkSinkConnectorConfig.java | 93 ++++++++++ .../CamelAwsbedrockagentruntimesinkSinkTask.java} | 16 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../aws-bedrock-agent-runtime-sink.kamelet.yaml | 132 ++++++++++++++ .../pom.xml | 16 +- .../descriptors/connector-sink.properties | 1 + .../camel-aws-bedrock-text-sink-sink.json | 83 +++++++++ .../src/main/assembly/package.xml | 0 ...amelAwsbedrocktextsinkSinkConnector.properties} | 14 +- .../CamelAwsbedrocktextsinkSinkConnector.java} | 10 +- ...CamelAwsbedrocktextsinkSinkConnectorConfig.java | 89 +++++++++ .../CamelAwsbedrocktextsinkSinkTask.java} | 16 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kamelets/aws-bedrock-text-sink.kamelet.yaml | 132 ++++++++++++++ .../pom.xml | 2 +- .../camel-aws-cloudtrail-source-source.json | 28 ++- ...elAwscloudtrailsourceSourceConnectorConfig.java | 16 ++ .../kamelets/aws-cloudtrail-source.kamelet.yaml | 96 +++++++++- .../pom.xml | 2 +- .../resources/camel-aws-cloudwatch-sink-sink.json | 30 ++- .../CamelAwscloudwatchsinkSinkConnectorConfig.java | 18 +- .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 29 ++- .../camel-aws-ddb-sink-kafka-connector/pom.xml | 4 +- .../resources/camel-aws-ddb-sink-sink.json | 28 ++- .../CamelAwsddbsinkSinkConnectorConfig.java | 16 ++ .../resources/kamelets/aws-ddb-sink.kamelet.yaml | 29 ++- .../pom.xml | 12 +- .../camel-aws-ddb-streams-source-source.json | 28 ++- ...elAwsddbstreamssourceSourceConnectorConfig.java | 16 ++ .../kamelets/aws-ddb-streams-source.kamelet.yaml | 29 ++- .../camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-aws-ec2-sink-sink.json | 30 ++- .../CamelAwsec2sinkSinkConnectorConfig.java | 18 +- .../resources/kamelets/aws-ec2-sink.kamelet.yaml | 29 ++- .../pom.xml | 2 +- .../resources/camel-aws-eventbridge-sink-sink.json | 28 ++- ...CamelAwseventbridgesinkSinkConnectorConfig.java | 16 ++ .../kamelets/aws-eventbridge-sink.kamelet.yaml | 27 ++- .../pom.xml | 2 +- .../camel-aws-kinesis-firehose-sink-sink.json | 28 ++- ...lAwskinesisfirehosesinkSinkConnectorConfig.java | 16 ++ .../aws-kinesis-firehose-sink.kamelet.yaml | 27 ++- .../camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-aws-kinesis-sink-sink.json | 28 ++- .../CamelAwskinesissinkSinkConnectorConfig.java | 16 ++ .../kamelets/aws-kinesis-sink.kamelet.yaml | 27 ++- .../pom.xml | 4 +- .../resources/camel-aws-kinesis-source-source.json | 42 ++++- ...CamelAwskinesissourceSourceConnectorConfig.java | 24 +++ .../kamelets/aws-kinesis-source.kamelet.yaml | 41 ++++- .../camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-aws-lambda-sink-sink.json | 28 ++- .../CamelAwslambdasinkSinkConnectorConfig.java | 16 ++ .../kamelets/aws-lambda-sink.kamelet.yaml | 29 ++- .../pom.xml | 18 +- .../resources/camel-aws-redshift-sink-sink.json | 2 +- .../kamelets/aws-redshift-sink.kamelet.yaml | 6 +- .../pom.xml | 18 +- .../camel-aws-redshift-source-source.json | 2 +- .../kamelets/aws-redshift-source.kamelet.yaml | 6 +- .../descriptors/connector-source.properties | 1 - .../CamelAwss3cdcsourceSourceConnectorConfig.java | 101 ---------- .../pom.xml | 8 +- .../descriptors/connector-source.properties | 1 + .../camel-aws-s3-event-based-source-source.json} | 66 +++---- .../src/main/assembly/package.xml | 0 ...wss3eventbasedsourceSourceConnector.properties} | 12 +- ...CamelAwss3eventbasedsourceSourceConnector.java} | 8 +- ...Awss3eventbasedsourceSourceConnectorConfig.java | 101 ++++++++++ .../CamelAwss3eventbasedsourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../aws-s3-event-based-source.kamelet.yaml} | 29 ++- .../camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-aws-s3-sink-sink.json | 28 ++- .../CamelAwss3sinkSinkConnectorConfig.java | 16 ++ .../resources/kamelets/aws-s3-sink.kamelet.yaml | 27 ++- .../camel-aws-s3-source-kafka-connector/pom.xml | 4 +- .../resources/camel-aws-s3-source-source.json | 53 +++++- .../CamelAwss3sourceSourceConnectorConfig.java | 32 ++++ .../resources/kamelets/aws-s3-source.kamelet.yaml | 67 ++++++- .../pom.xml | 2 +- .../camel-aws-s3-streaming-upload-sink-sink.json | 28 ++- ...wss3streaminguploadsinkSinkConnectorConfig.java | 16 ++ .../aws-s3-streaming-upload-sink.kamelet.yaml | 27 ++- .../pom.xml | 2 +- .../camel-aws-secrets-manager-sink-sink.json | 28 ++- ...elAwssecretsmanagersinkSinkConnectorConfig.java | 16 ++ .../kamelets/aws-secrets-manager-sink.kamelet.yaml | 29 ++- .../camel-aws-ses-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-aws-ses-sink-sink.json | 28 ++- .../CamelAwssessinkSinkConnectorConfig.java | 16 ++ .../resources/kamelets/aws-ses-sink.kamelet.yaml | 29 ++- .../pom.xml | 2 +- .../resources/camel-aws-sns-fifo-sink-sink.json | 28 ++- .../CamelAwssnsfifosinkSinkConnectorConfig.java | 16 ++ .../kamelets/aws-sns-fifo-sink.kamelet.yaml | 31 +++- .../camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-aws-sns-sink-sink.json | 28 ++- .../CamelAwssnssinkSinkConnectorConfig.java | 16 ++ .../resources/kamelets/aws-sns-sink.kamelet.yaml | 27 ++- .../pom.xml | 2 +- .../resources/camel-aws-sqs-batch-sink-sink.json | 28 ++- .../CamelAwssqsbatchsinkSinkConnectorConfig.java | 16 ++ .../kamelets/aws-sqs-batch-sink.kamelet.yaml | 27 ++- .../pom.xml | 2 +- .../resources/camel-aws-sqs-fifo-sink-sink.json | 28 ++- .../CamelAwssqsfifosinkSinkConnectorConfig.java | 16 ++ .../kamelets/aws-sqs-fifo-sink.kamelet.yaml | 35 +++- .../camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-aws-sqs-sink-sink.json | 28 ++- .../CamelAwssqssinkSinkConnectorConfig.java | 16 ++ .../resources/kamelets/aws-sqs-sink.kamelet.yaml | 27 ++- .../camel-aws-sqs-source-kafka-connector/pom.xml | 4 +- .../resources/camel-aws-sqs-source-source.json | 47 ++++- .../CamelAwssqssourceSourceConnectorConfig.java | 28 +++ .../resources/kamelets/aws-sqs-source.kamelet.yaml | 49 ++++- .../pom.xml | 2 +- .../camel-aws-timestream-query-sink-sink.json | 28 ++- ...lAwstimestreamquerysinkSinkConnectorConfig.java | 16 ++ .../aws-timestream-query-sink.kamelet.yaml | 27 ++- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-aws2-iam-sink.json | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-aws2-kms-sink.json | 10 +- .../aws2kms/CamelAws2kmsSinkConnectorConfig.java | 4 +- .../pom.xml | 2 +- .../resources/camel-azure-cosmosdb-sink-sink.json | 2 +- .../kamelets/azure-cosmosdb-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-azure-cosmosdb-source-source.json | 2 +- .../kamelets/azure-cosmosdb-source.kamelet.yaml | 41 ++++- .../pom.xml | 2 +- .../resources/camel-azure-eventhubs-sink-sink.json | 2 +- .../kamelets/azure-eventhubs-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-azure-eventhubs-source-source.json | 2 +- .../kamelets/azure-eventhubs-source.kamelet.yaml | 68 ++++++- .../pom.xml | 2 +- .../resources/camel-azure-functions-sink-sink.json | 2 +- .../kamelets/azure-functions-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-azure-servicebus-sink-sink.json | 2 +- .../kamelets/azure-servicebus-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-azure-servicebus-source-source.json | 2 +- .../kamelets/azure-servicebus-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-azure-storage-blob-append-sink-sink.json | 2 +- .../azure-storage-blob-append-sink.kamelet.yaml | 2 +- .../descriptors/connector-source.properties | 1 - ...estorageblobcdcsourceSourceConnectorConfig.java | 81 -------- .../pom.xml | 2 +- ...zure-storage-blob-changefeed-source-source.json | 2 +- ...ure-storage-blob-changefeed-source.kamelet.yaml | 2 +- .../pom.xml | 8 +- .../descriptors/connector-source.properties | 1 + ...re-storage-blob-event-based-source-source.json} | 46 ++--- .../src/main/assembly/package.xml | 0 ...blobeventbasedsourceSourceConnector.properties} | 14 +- ...torageblobeventbasedsourceSourceConnector.java} | 8 +- ...eblobeventbasedsourceSourceConnectorConfig.java | 81 ++++++++ ...zurestorageblobeventbasedsourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...e-storage-blob-event-based-source.kamelet.yaml} | 10 +- .../pom.xml | 2 +- .../camel-azure-storage-blob-sink-sink.json | 2 +- .../kamelets/azure-storage-blob-sink.kamelet.yaml | 2 +- .../pom.xml | 4 +- .../camel-azure-storage-blob-source-source.json | 2 +- .../azure-storage-blob-source.kamelet.yaml | 4 +- .../pom.xml | 4 +- .../camel-azure-storage-datalake-sink-sink.json | 2 +- .../azure-storage-datalake-sink.kamelet.yaml | 4 +- .../pom.xml | 4 +- ...camel-azure-storage-datalake-source-source.json | 2 +- .../azure-storage-datalake-source.kamelet.yaml | 145 ++++++++++++++- .../pom.xml | 2 +- .../camel-azure-storage-files-sink-sink.json | 2 +- .../kamelets/azure-storage-files-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-azure-storage-files-source-source.json | 2 +- .../azure-storage-files-source.kamelet.yaml | 93 +++++++++- .../pom.xml | 2 +- .../camel-azure-storage-queue-sink-sink.json | 2 +- .../kamelets/azure-storage-queue-sink.kamelet.yaml | 2 +- .../pom.xml | 4 +- .../camel-azure-storage-queue-source-source.json | 2 +- .../azure-storage-queue-source.kamelet.yaml | 6 +- .../camel-beer-source-kafka-connector/pom.xml | 2 +- .../resources/camel-beer-source-source.json | 2 +- .../resources/kamelets/beer-source.kamelet.yaml | 19 +- .../camel-bitcoin-source-kafka-connector/pom.xml | 2 +- .../resources/camel-bitcoin-source-source.json | 2 +- .../resources/kamelets/bitcoin-source.kamelet.yaml | 2 +- .../camel-cassandra-sink-kafka-connector/pom.xml | 6 +- .../resources/camel-cassandra-sink-sink.json | 9 +- .../CamelCassandrasinkSinkConnectorConfig.java | 4 + .../resources/kamelets/cassandra-sink.kamelet.yaml | 21 ++- .../camel-cassandra-source-kafka-connector/pom.xml | 2 +- .../resources/camel-cassandra-source-source.json | 2 +- .../kamelets/cassandra-source.kamelet.yaml | 2 +- connectors/camel-ceph-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-ceph-sink-sink.json | 2 +- .../main/resources/kamelets/ceph-sink.kamelet.yaml | 2 +- .../camel-ceph-source-kafka-connector/pom.xml | 2 +- .../resources/camel-ceph-source-source.json | 2 +- .../resources/kamelets/ceph-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-chuck-norris-source-source.json | 2 +- .../kamelets/chuck-norris-source.kamelet.yaml | 2 +- .../camel-coffee-source-kafka-connector/pom.xml | 2 +- .../resources/camel-coffee-source-source.json | 2 +- .../resources/kamelets/coffee-source.kamelet.yaml | 19 +- .../camel-couchbase-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-couchbase-sink-sink.json | 2 +- .../resources/kamelets/couchbase-sink.kamelet.yaml | 2 +- .../pom.xml | 16 +- .../descriptors/connector-source.properties | 1 + .../resources/camel-counter-source-source.json | 33 ++++ .../src/main/assembly/package.xml | 0 .../CamelCountersourceSourceConnector.properties} | 10 +- .../CamelCountersourceSourceConnector.java} | 8 +- .../CamelCountersourceSourceConnectorConfig.java | 57 ++++++ .../CamelCountersourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kamelets/counter-source.kamelet.yaml} | 52 +++--- .../camel-cron-source-kafka-connector/pom.xml | 2 +- .../resources/camel-cron-source-source.json | 2 +- .../resources/kamelets/cron-source.kamelet.yaml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- .../src/generated/resources/camel-cxf-sink.json | 2 +- .../src/generated/resources/camel-cxf-source.json | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml | 2 +- .../src/generated/resources/camel-cxfrs-sink.json | 2 +- .../generated/resources/camel-cxfrs-source.json | 2 +- .../camel-dropbox-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-dropbox-sink-sink.json | 2 +- .../resources/kamelets/dropbox-sink.kamelet.yaml | 2 +- .../camel-dropbox-source-kafka-connector/pom.xml | 2 +- .../resources/camel-dropbox-source-source.json | 2 +- .../resources/kamelets/dropbox-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-earthquake-source-source.json | 2 +- .../kamelets/earthquake-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-elasticsearch-index-sink-sink.json | 2 +- .../kamelets/elasticsearch-index-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-elasticsearch-search-source-source.json | 2 +- .../elasticsearch-search-source.kamelet.yaml | 2 +- connectors/camel-exec-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-exec-sink-sink.json | 2 +- .../main/resources/kamelets/exec-sink.kamelet.yaml | 2 +- connectors/camel-fhir-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-fhir-sink-sink.json | 2 +- .../main/resources/kamelets/fhir-sink.kamelet.yaml | 29 ++- .../camel-fhir-source-kafka-connector/pom.xml | 2 +- .../resources/camel-fhir-source-source.json | 2 +- .../resources/kamelets/fhir-source.kamelet.yaml | 2 +- connectors/camel-file-kafka-connector/pom.xml | 2 +- .../src/generated/resources/camel-file-sink.json | 12 +- .../src/generated/resources/camel-file-source.json | 19 +- .../file/CamelFileSinkConnectorConfig.java | 10 +- .../file/CamelFileSourceConnectorConfig.java | 14 +- .../pom.xml | 2 +- .../resources/camel-file-watch-source-source.json | 2 +- .../kamelets/file-watch-source.kamelet.yaml | 2 +- connectors/camel-ftp-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-ftp-sink-sink.json | 2 +- .../main/resources/kamelets/ftp-sink.kamelet.yaml | 2 +- .../camel-ftp-source-kafka-connector/pom.xml | 2 +- .../resources/camel-ftp-source-source.json | 2 +- .../resources/kamelets/ftp-source.kamelet.yaml | 2 +- connectors/camel-ftps-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-ftps-sink-sink.json | 2 +- .../main/resources/kamelets/ftps-sink.kamelet.yaml | 2 +- .../camel-ftps-source-kafka-connector/pom.xml | 2 +- .../resources/camel-ftps-source-source.json | 2 +- .../resources/kamelets/ftps-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-github-commit-source-source.json | 2 +- .../kamelets/github-commit-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-github-event-source-source.json | 2 +- .../kamelets/github-event-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- ...l-github-pullrequest-comment-source-source.json | 2 +- .../github-pullrequest-comment-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-github-pullrequest-source-source.json | 2 +- .../github-pullrequest-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-github-tag-source-source.json | 2 +- .../kamelets/github-tag-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-google-bigquery-sink-sink.json | 2 +- .../kamelets/google-bigquery-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-google-calendar-source-source.json | 2 +- .../kamelets/google-calendar-source.kamelet.yaml | 44 ++++- .../pom.xml | 2 +- .../camel-google-functions-sink-sink.json | 2 +- .../kamelets/google-functions-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-google-mail-source-source.json | 2 +- .../kamelets/google-mail-source.kamelet.yaml | 64 ++++++- .../pom.xml | 2 +- .../resources/camel-google-pubsub-sink-sink.json | 2 +- .../kamelets/google-pubsub-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-google-pubsub-source-source.json | 2 +- .../kamelets/google-pubsub-source.kamelet.yaml | 2 +- .../pom.xml | 4 +- .../resources/camel-google-sheets-sink-sink.json | 2 +- .../kamelets/google-sheets-sink.kamelet.yaml | 4 +- .../pom.xml | 2 +- .../camel-google-sheets-source-source.json | 2 +- .../kamelets/google-sheets-source.kamelet.yaml | 29 ++- .../descriptors/connector-source.properties | 1 - ...ooglestoragecdcsourceSourceConnectorConfig.java | 77 -------- .../pom.xml | 8 +- .../descriptors/connector-source.properties | 1 + ...-google-storage-event-based-source-source.json} | 42 ++--- .../src/main/assembly/package.xml | 0 ...rageeventbasedsourceSourceConnector.properties} | 12 +- ...glestorageeventbasedsourceSourceConnector.java} | 8 +- ...orageeventbasedsourceSourceConnectorConfig.java | 77 ++++++++ ...elGooglestorageeventbasedsourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...google-storage-event-based-source.kamelet.yaml} | 8 +- .../pom.xml | 2 +- .../resources/camel-google-storage-sink-sink.json | 2 +- .../kamelets/google-storage-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-google-storage-source-source.json | 2 +- .../kamelets/google-storage-source.kamelet.yaml | 2 +- .../camel-graphql-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-graphql-sink-sink.json | 2 +- .../resources/kamelets/graphql-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-http-secured-sink-sink.json | 29 ++- .../CamelHttpsecuredsinkSinkConnectorConfig.java | 18 +- .../kamelets/http-secured-sink.kamelet.yaml | 41 ++++- .../pom.xml | 2 +- .../camel-http-secured-source-source.json | 29 ++- ...amelHttpsecuredsourceSourceConnectorConfig.java | 18 +- .../kamelets/http-secured-source.kamelet.yaml | 41 ++++- connectors/camel-http-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-http-sink-sink.json | 2 +- .../main/resources/kamelets/http-sink.kamelet.yaml | 2 +- .../camel-http-source-kafka-connector/pom.xml | 2 +- .../resources/camel-http-source-source.json | 2 +- .../resources/kamelets/http-source.kamelet.yaml | 2 +- connectors/camel-https-kafka-connector/pom.xml | 2 +- .../src/generated/resources/camel-https-sink.json | 94 +++++----- .../https/CamelHttpsSinkConnectorConfig.java | 56 +++--- .../camel-infinispan-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-infinispan-sink-sink.json | 2 +- .../kamelets/infinispan-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-infinispan-source-source.json | 2 +- .../kamelets/infinispan-source.kamelet.yaml | 2 +- connectors/camel-jdbc-kafka-connector/pom.xml | 2 +- .../src/generated/resources/camel-jdbc-sink.json | 2 +- .../camel-jms-amqp-10-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-jms-amqp-10-sink-sink.json | 2 +- .../kamelets/jms-amqp-10-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-jms-amqp-10-source-source.json | 2 +- .../kamelets/jms-amqp-10-source.kamelet.yaml | 2 +- .../pom.xml | 12 +- .../camel-jms-apache-artemis-sink-sink.json | 2 +- .../kamelets/jms-apache-artemis-sink.kamelet.yaml | 4 +- .../pom.xml | 12 +- .../camel-jms-apache-artemis-source-source.json | 4 +- ...msapacheartemissourceSourceConnector.properties | 2 +- ...msapacheartemissourceSourceConnectorConfig.java | 2 +- .../jms-apache-artemis-source.kamelet.yaml | 6 +- .../camel-jms-ibm-mq-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-jms-ibm-mq-sink-sink.json | 2 +- .../kamelets/jms-ibm-mq-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-jms-ibm-mq-source-source.json | 2 +- .../kamelets/jms-ibm-mq-source.kamelet.yaml | 2 +- .../pom.xml | 23 ++- .../descriptors/connector-sink.properties | 1 + .../camel-jms-pooled-apache-artemis-sink-sink.json | 65 +++++++ .../src/main/assembly/package.xml | 0 ...ooledapacheartemissinkSinkConnector.properties} | 14 +- ...elJmspooledapacheartemissinkSinkConnector.java} | 12 +- ...pooledapacheartemissinkSinkConnectorConfig.java | 77 ++++++++ .../CamelJmspooledapacheartemissinkSinkTask.java} | 16 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../jms-pooled-apache-artemis-sink.kamelet.yaml} | 53 +++++- .../pom.xml | 23 ++- .../descriptors/connector-source.properties | 1 + ...el-jms-pooled-apache-artemis-source-source.json | 65 +++++++ .../src/main/assembly/package.xml | 0 ...dapacheartemissourceSourceConnector.properties} | 10 +- ...spooledapacheartemissourceSourceConnector.java} | 8 +- ...edapacheartemissourceSourceConnectorConfig.java | 77 ++++++++ ...melJmspooledapacheartemissourceSourceTask.java} | 10 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../jms-pooled-apache-artemis-source.kamelet.yaml} | 55 +++++- .../pom.xml | 2 +- ...ka-apicurio-registry-not-secured-sink-sink.json | 4 +- ...apicurio-registry-not-secured-sink.kamelet.yaml | 4 +- .../descriptors/connector-source.properties | 1 - ...picurio-registry-not-secured-source-source.json | 93 ---------- .../src/main/assembly/package.xml | 56 ------ ...istrynotsecuredsourceSourceConnectorConfig.java | 93 ---------- .../src/main/resources/META-INF/LICENSE.txt | 203 --------------------- .../src/main/resources/META-INF/NOTICE.txt | 11 -- .../pom.xml | 24 +-- ...amel-kafka-azure-schema-registry-sink-sink.json | 2 +- .../kafka-azure-schema-registry-sink.kamelet.yaml | 8 +- .../pom.xml | 24 +-- ...-kafka-azure-schema-registry-source-source.json | 2 +- ...kafka-azure-schema-registry-source.kamelet.yaml | 8 +- .../pom.xml | 4 +- ...picurio-registry-not-secured-source-source.json | 9 +- ...istrynotsecuredsourceSourceConnectorConfig.java | 4 + ...icurio-registry-not-secured-source.kamelet.yaml | 10 +- .../pom.xml | 10 +- .../descriptors/connector-source.properties | 1 + ...afka-batch-apicurio-registry-source-source.json | 149 +++++++++++++++ .../src/main/assembly/package.xml | 0 ...icurioregistrysourceSourceConnector.properties} | 22 ++- ...atchapicurioregistrysourceSourceConnector.java} | 8 +- ...picurioregistrysourceSourceConnectorConfig.java | 129 +++++++++++++ ...afkabatchapicurioregistrysourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...ka-batch-apicurio-registry-source.kamelet.yaml} | 63 ++++++- .../pom.xml | 24 +-- ...-batch-azure-schema-registry-source-source.json | 9 +- ...eschemaregistrysourceSourceConnectorConfig.java | 4 + ...batch-azure-schema-registry-source.kamelet.yaml | 14 +- .../pom.xml | 4 +- ...amel-kafka-batch-not-secured-source-source.json | 9 +- ...batchnotsecuredsourceSourceConnectorConfig.java | 4 + .../kafka-batch-not-secured-source.kamelet.yaml | 10 +- .../pom.xml | 4 +- .../camel-kafka-batch-scram-source-source.json | 9 +- ...KafkabatchscramsourceSourceConnectorConfig.java | 4 + .../kamelets/kafka-batch-scram-source.kamelet.yaml | 10 +- .../pom.xml | 4 +- .../resources/camel-kafka-batch-source-source.json | 9 +- ...CamelKafkabatchsourceSourceConnectorConfig.java | 4 + .../kamelets/kafka-batch-source.kamelet.yaml | 12 +- .../pom.xml | 4 +- .../camel-kafka-batch-ssl-source-source.json | 9 +- ...elKafkabatchsslsourceSourceConnectorConfig.java | 4 + .../kamelets/kafka-batch-ssl-source.kamelet.yaml | 10 +- .../pom.xml | 16 +- .../descriptors/connector-source.properties | 1 + ...cured-apicurio-registry-json-source-source.json | 122 +++++++++++++ .../src/main/assembly/package.xml | 0 ...ioregistryjsonsourceSourceConnector.properties} | 22 ++- ...apicurioregistryjsonsourceSourceConnector.java} | 8 +- ...rioregistryjsonsourceSourceConnectorConfig.java | 113 ++++++++++++ ...curedapicurioregistryjsonsourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...red-apicurio-registry-json-source.kamelet.yaml} | 65 +++++-- .../pom.xml | 8 +- .../descriptors/connector-sink.properties | 1 + ...ka-not-secured-apicurio-registry-sink-sink.json | 81 ++++++++ .../src/main/assembly/package.xml | 0 ...edapicurioregistrysinkSinkConnector.properties} | 24 ++- ...tsecuredapicurioregistrysinkSinkConnector.java} | 12 +- ...redapicurioregistrysinkSinkConnectorConfig.java | 89 +++++++++ ...fkanotsecuredapicurioregistrysinkSinkTask.java} | 18 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...ot-secured-apicurio-registry-sink.kamelet.yaml} | 59 +++++- .../pom.xml | 10 +- .../descriptors/connector-source.properties | 1 + ...ot-secured-apicurio-registry-source-source.json | 129 +++++++++++++ .../src/main/assembly/package.xml | 0 ...icurioregistrysourceSourceConnector.properties} | 22 ++- ...uredapicurioregistrysourceSourceConnector.java} | 8 +- ...picurioregistrysourceSourceConnectorConfig.java | 117 ++++++++++++ ...otsecuredapicurioregistrysourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...-secured-apicurio-registry-source.kamelet.yaml} | 57 +++++- .../pom.xml | 4 +- .../camel-kafka-not-secured-sink-sink.json | 4 +- .../kamelets/kafka-not-secured-sink.kamelet.yaml | 6 +- .../pom.xml | 4 +- .../camel-kafka-not-secured-source-source.json | 2 +- .../kamelets/kafka-not-secured-source.kamelet.yaml | 4 +- .../camel-kafka-scram-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-kafka-scram-sink-sink.json | 2 +- .../kamelets/kafka-scram-sink.kamelet.yaml | 2 +- .../pom.xml | 4 +- .../resources/camel-kafka-scram-source-source.json | 2 +- .../kamelets/kafka-scram-source.kamelet.yaml | 4 +- .../camel-kafka-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-kafka-sink-sink.json | 2 +- .../resources/kamelets/kafka-sink.kamelet.yaml | 2 +- .../camel-kafka-source-kafka-connector/pom.xml | 4 +- .../resources/camel-kafka-source-source.json | 2 +- .../resources/kamelets/kafka-source.kamelet.yaml | 4 +- .../camel-kafka-ssl-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-kafka-ssl-sink-sink.json | 2 +- .../resources/kamelets/kafka-ssl-sink.kamelet.yaml | 2 +- .../camel-kafka-ssl-source-kafka-connector/pom.xml | 4 +- .../resources/camel-kafka-ssl-source-source.json | 2 +- .../kamelets/kafka-ssl-source.kamelet.yaml | 4 +- .../pom.xml | 2 +- .../camel-kubernetes-namespaces-source-source.json | 2 +- .../kubernetes-namespaces-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-kubernetes-nodes-source-source.json | 2 +- .../kamelets/kubernetes-nodes-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-kubernetes-pods-source-source.json | 2 +- .../kamelets/kubernetes-pods-source.kamelet.yaml | 2 +- connectors/camel-log-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-log-sink-sink.json | 2 +- .../main/resources/kamelets/log-sink.kamelet.yaml | 2 +- .../camel-mail-imap-source-kafka-connector/pom.xml | 2 +- .../resources/camel-mail-imap-source-source.json | 2 +- .../kamelets/mail-imap-source.kamelet.yaml | 2 +- connectors/camel-mail-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-mail-sink-sink.json | 2 +- .../main/resources/kamelets/mail-sink.kamelet.yaml | 2 +- .../camel-mariadb-sink-kafka-connector/pom.xml | 12 +- .../resources/camel-mariadb-sink-sink.json | 2 +- .../resources/kamelets/mariadb-sink.kamelet.yaml | 4 +- .../camel-mariadb-source-kafka-connector/pom.xml | 12 +- .../resources/camel-mariadb-source-source.json | 2 +- .../resources/kamelets/mariadb-source.kamelet.yaml | 4 +- .../camel-minio-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-minio-sink-sink.json | 2 +- .../resources/kamelets/minio-sink.kamelet.yaml | 2 +- .../camel-minio-source-kafka-connector/pom.xml | 2 +- .../resources/camel-minio-source-source.json | 2 +- .../resources/kamelets/minio-source.kamelet.yaml | 2 +- .../pom.xml | 4 +- ...camel-mongodb-changes-stream-source-source.json | 2 +- .../mongodb-changes-stream-source.kamelet.yaml | 4 +- .../camel-mongodb-sink-kafka-connector/pom.xml | 4 +- .../resources/camel-mongodb-sink-sink.json | 2 +- .../resources/kamelets/mongodb-sink.kamelet.yaml | 4 +- .../camel-mongodb-source-kafka-connector/pom.xml | 4 +- .../resources/camel-mongodb-source-source.json | 2 +- .../resources/kamelets/mongodb-source.kamelet.yaml | 4 +- connectors/camel-mqtt-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-mqtt-sink-sink.json | 2 +- .../main/resources/kamelets/mqtt-sink.kamelet.yaml | 2 +- .../camel-mqtt-source-kafka-connector/pom.xml | 2 +- .../resources/camel-mqtt-source-source.json | 2 +- .../resources/kamelets/mqtt-source.kamelet.yaml | 2 +- .../camel-mqtt5-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-mqtt5-sink-sink.json | 2 +- .../resources/kamelets/mqtt5-sink.kamelet.yaml | 2 +- .../camel-mqtt5-source-kafka-connector/pom.xml | 2 +- .../resources/camel-mqtt5-source-source.json | 2 +- .../resources/kamelets/mqtt5-source.kamelet.yaml | 2 +- .../camel-mysql-sink-kafka-connector/pom.xml | 12 +- .../generated/resources/camel-mysql-sink-sink.json | 2 +- .../resources/kamelets/mysql-sink.kamelet.yaml | 4 +- .../camel-mysql-source-kafka-connector/pom.xml | 12 +- .../resources/camel-mysql-source-source.json | 2 +- .../resources/kamelets/mysql-source.kamelet.yaml | 4 +- connectors/camel-nats-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-nats-sink-sink.json | 2 +- .../main/resources/kamelets/nats-sink.kamelet.yaml | 2 +- .../camel-nats-source-kafka-connector/pom.xml | 2 +- .../resources/camel-nats-source-source.json | 2 +- .../resources/kamelets/nats-source.kamelet.yaml | 2 +- .../camel-netty-http-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-netty-http-sink.json | 2 +- .../resources/camel-netty-http-source.json | 2 +- connectors/camel-netty-kafka-connector/pom.xml | 2 +- .../src/generated/resources/camel-netty-sink.json | 2 +- .../generated/resources/camel-netty-source.json | 2 +- .../pom.xml | 2 +- .../camel-opensearch-index-sink-sink.json | 2 +- .../kamelets/opensearch-index-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-opensearch-search-source-source.json | 2 +- .../kamelets/opensearch-search-source.kamelet.yaml | 2 +- .../pom.xml | 12 +- .../resources/camel-oracle-database-sink-sink.json | 2 +- .../kamelets/oracle-database-sink.kamelet.yaml | 4 +- .../pom.xml | 12 +- .../camel-oracle-database-source-source.json | 2 +- .../kamelets/oracle-database-source.kamelet.yaml | 4 +- .../camel-postgresql-sink-kafka-connector/pom.xml | 18 +- .../resources/camel-postgresql-sink-sink.json | 2 +- .../kamelets/postgresql-sink.kamelet.yaml | 6 +- .../pom.xml | 18 +- .../resources/camel-postgresql-source-source.json | 2 +- .../kamelets/postgresql-source.kamelet.yaml | 6 +- .../camel-pulsar-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-pulsar-sink-sink.json | 2 +- .../resources/kamelets/pulsar-sink.kamelet.yaml | 2 +- .../camel-pulsar-source-kafka-connector/pom.xml | 2 +- .../resources/camel-pulsar-source-source.json | 2 +- .../resources/kamelets/pulsar-source.kamelet.yaml | 2 +- .../camel-redis-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-redis-sink-sink.json | 2 +- .../resources/kamelets/redis-sink.kamelet.yaml | 2 +- .../camel-redis-source-kafka-connector/pom.xml | 2 +- .../resources/camel-redis-source-source.json | 2 +- .../resources/kamelets/redis-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-rest-openapi-sink-sink.json | 2 +- .../kamelets/rest-openapi-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- ...amel-salesforce-composite-upsert-sink-sink.json | 2 +- .../salesforce-composite-upsert-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-salesforce-create-sink-sink.json | 2 +- .../kamelets/salesforce-create-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-salesforce-delete-sink-sink.json | 2 +- .../kamelets/salesforce-delete-sink.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-salesforce-source-source.json | 8 +- ...CamelSalesforcesourceSourceConnectorConfig.java | 4 + .../kamelets/salesforce-source.kamelet.yaml | 7 +- .../pom.xml | 2 +- .../camel-salesforce-update-sink-sink.json | 4 +- .../kamelets/salesforce-update-sink.kamelet.yaml | 33 ++-- connectors/camel-scp-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-scp-sink-sink.json | 2 +- .../main/resources/kamelets/scp-sink.kamelet.yaml | 2 +- connectors/camel-sftp-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-sftp-sink-sink.json | 2 +- .../main/resources/kamelets/sftp-sink.kamelet.yaml | 2 +- .../camel-sftp-source-kafka-connector/pom.xml | 2 +- .../resources/camel-sftp-source-source.json | 2 +- .../resources/kamelets/sftp-source.kamelet.yaml | 2 +- connectors/camel-sjms2-kafka-connector/pom.xml | 2 +- .../src/generated/resources/camel-sjms2-sink.json | 2 +- .../generated/resources/camel-sjms2-source.json | 2 +- .../camel-slack-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-slack-sink-sink.json | 2 +- .../resources/kamelets/slack-sink.kamelet.yaml | 2 +- .../camel-slack-source-kafka-connector/pom.xml | 2 +- .../resources/camel-slack-source-source.json | 11 +- .../CamelSlacksourceSourceConnectorConfig.java | 6 +- .../resources/kamelets/slack-source.kamelet.yaml | 47 ++++- .../camel-snowflake-sink-kafka-connector/pom.xml | 14 +- .../resources/camel-snowflake-sink-sink.json | 2 +- .../resources/kamelets/snowflake-sink.kamelet.yaml | 6 +- .../camel-snowflake-source-kafka-connector/pom.xml | 14 +- .../resources/camel-snowflake-source-source.json | 2 +- .../kamelets/snowflake-source.kamelet.yaml | 6 +- .../camel-splunk-hec-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-splunk-hec-sink-sink.json | 2 +- .../kamelets/splunk-hec-sink.kamelet.yaml | 2 +- .../camel-splunk-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-splunk-sink-sink.json | 2 +- .../resources/kamelets/splunk-sink.kamelet.yaml | 2 +- .../camel-splunk-source-kafka-connector/pom.xml | 2 +- .../resources/camel-splunk-source-source.json | 2 +- .../resources/kamelets/splunk-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../resources/camel-spring-rabbitmq-sink-sink.json | 16 +- ...CamelSpringrabbitmqsinkSinkConnectorConfig.java | 8 + .../kamelets/spring-rabbitmq-sink.kamelet.yaml | 16 +- .../pom.xml | 2 +- .../camel-spring-rabbitmq-source-source.json | 9 +- ...lSpringrabbitmqsourceSourceConnectorConfig.java | 4 + .../kamelets/spring-rabbitmq-source.kamelet.yaml | 8 +- .../camel-sqlserver-sink-kafka-connector/pom.xml | 12 +- .../resources/camel-sqlserver-sink-sink.json | 2 +- .../resources/kamelets/sqlserver-sink.kamelet.yaml | 4 +- .../camel-sqlserver-source-kafka-connector/pom.xml | 12 +- .../resources/camel-sqlserver-source-source.json | 2 +- .../kamelets/sqlserver-source.kamelet.yaml | 4 +- connectors/camel-ssh-sink-kafka-connector/pom.xml | 2 +- .../generated/resources/camel-ssh-sink-sink.json | 2 +- .../main/resources/kamelets/ssh-sink.kamelet.yaml | 2 +- .../camel-ssh-source-kafka-connector/pom.xml | 2 +- .../resources/camel-ssh-source-source.json | 2 +- .../resources/kamelets/ssh-source.kamelet.yaml | 2 +- connectors/camel-syslog-kafka-connector/pom.xml | 2 +- .../CamelStreamCacheConverterLoader.java | 6 +- .../camel-telegram-sink-kafka-connector/pom.xml | 2 +- .../resources/camel-telegram-sink-sink.json | 2 +- .../resources/kamelets/telegram-sink.kamelet.yaml | 2 +- .../camel-telegram-source-kafka-connector/pom.xml | 2 +- .../resources/camel-telegram-source-source.json | 2 +- .../kamelets/telegram-source.kamelet.yaml | 2 +- .../camel-timer-source-kafka-connector/pom.xml | 2 +- .../resources/camel-timer-source-source.json | 2 +- .../resources/kamelets/timer-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-twitter-directmessage-source-source.json | 2 +- .../twitter-directmessage-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-twitter-search-source-source.json | 2 +- .../kamelets/twitter-search-source.kamelet.yaml | 2 +- .../pom.xml | 2 +- .../camel-twitter-timeline-source-source.json | 2 +- .../kamelets/twitter-timeline-source.kamelet.yaml | 2 +- .../camel-webhook-source-kafka-connector/pom.xml | 2 +- .../resources/camel-webhook-source-source.json | 2 +- .../resources/kamelets/webhook-source.kamelet.yaml | 2 +- .../camel-wttrin-source-kafka-connector/pom.xml | 2 +- .../resources/camel-wttrin-source-source.json | 2 +- .../resources/kamelets/wttrin-source.kamelet.yaml | 2 +- connectors/pom.xml | 20 +- core/pom.xml | 2 +- distribution/pom.xml | 2 +- docs/modules/ROOT/nav.adoc | 32 +++- docs/modules/ROOT/pages/reference/index.adoc | 18 +- parent/pom.xml | 8 +- pom.xml | 4 +- tests/itests-aws-v2/pom.xml | 2 +- .../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 5 +- 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 +- tests/itests-couchbase/pom.xml | 2 +- tests/itests-cxf/pom.xml | 2 +- tests/itests-cxfrs/pom.xml | 2 +- tests/itests-elasticsearch/pom.xml | 2 +- tests/itests-file/pom.xml | 2 +- tests/itests-google-pubsub/pom.xml | 2 +- tests/itests-http/pom.xml | 2 +- tests/itests-https/pom.xml | 2 +- tests/itests-jdbc/pom.xml | 2 +- tests/itests-mongodb/pom.xml | 2 +- tests/itests-netty-http/pom.xml | 2 +- tests/itests-netty/pom.xml | 2 +- tests/itests-parent/pom.xml | 2 +- tests/itests-salesforce/pom.xml | 2 +- tests/itests-sjms2/pom.xml | 2 +- .../sjms2/common/FixedDispatchRouterContainer.java | 44 +++++ .../kafkaconnector/sjms2/common/SJMS2Common.java | 5 +- tests/itests-slack/pom.xml | 2 +- tests/itests-sql/pom.xml | 2 +- tests/itests-ssh/pom.xml | 2 +- tests/itests-syslog/pom.xml | 2 +- tests/itests-timer/pom.xml | 2 +- tests/pom.xml | 2 +- .../pom.xml | 2 +- .../pom.xml | 2 +- .../pom.xml | 2 +- tooling/camel-kafka-connector-model/pom.xml | 2 +- tooling/pom.xml | 2 +- 971 files changed, 8588 insertions(+), 2475 deletions(-) create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-bedrock-agent-runtime-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-bedrock-text-sink-sink.json copy connectors/camel-aws-s3-cdc-source-kafka-connector/src/generated/resources/camel-aws-s3-cdc-source-source.json => camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-event-based-source-source.json (58%) copy connectors/camel-azure-storage-blob-cdc-source-kafka-connector/src/generated/resources/camel-azure-storage-blob-cdc-source-source.json => camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-event-based-source-source.json (51%) create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-counter-source-source.json copy connectors/camel-google-storage-cdc-source-kafka-connector/src/generated/resources/camel-google-storage-cdc-source-source.json => camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-storage-event-based-source-source.json (54%) create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-jms-pooled-apache-artemis-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-jms-pooled-apache-artemis-source-source.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-batch-apicurio-registry-source-source.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-not-secured-apicurio-registry-json-source-source.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-not-secured-apicurio-registry-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-not-secured-apicurio-registry-source-source.json copy connectors/{camel-azure-storage-blob-append-sink-kafka-connector => camel-aws-bedrock-agent-runtime-sink-kafka-connector}/pom.xml (92%) create mode 100644 connectors/camel-aws-bedrock-agent-runtime-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-aws-bedrock-agent-runtime-sink-kafka-connector/src/generated/resources/camel-aws-bedrock-agent-runtime-sink-sink.json rename connectors/{camel-aws-s3-cdc-source-kafka-connector => camel-aws-bedrock-agent-runtime-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/docs/examples/CamelAwss3cdcsourceSourceConnector.properties => camel-aws-bedrock-agent-runtime-sink-kafka-connector/src/main/docs/examples/CamelAwsbedrockagentruntimesinkSinkConnector.properties} (71%) copy connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragecdcsource/CamelGooglestoragecdcsourceSourceConnector.java => camel-aws-bedrock-agent-runtime-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsbedrockagentruntimesink/CamelAwsbedrockagentruntimesinkSinkConnector.java} (77%) create mode 100644 connectors/camel-aws-bedrock-agent-runtime-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsbedrockagentruntimesink/CamelAwsbedrockagentruntimesinkSinkConnectorConfig.java copy connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3cdcsource/CamelAwss3cdcsourceSourceTask.java => camel-aws-bedrock-agent-runtime-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsbedrockagentruntimesink/CamelAwsbedrockagentruntimesinkSinkTask.java} (68%) rename connectors/{camel-aws-s3-cdc-source-kafka-connector => camel-aws-bedrock-agent-runtime-sink-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%) rename connectors/{camel-aws-s3-cdc-source-kafka-connector => camel-aws-bedrock-agent-runtime-sink-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-aws-bedrock-agent-runtime-sink-kafka-connector/src/main/resources/kamelets/aws-bedrock-agent-runtime-sink.kamelet.yaml copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-aws-bedrock-text-sink-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-aws-bedrock-text-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-aws-bedrock-text-sink-kafka-connector/src/generated/resources/camel-aws-bedrock-text-sink-sink.json rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector => camel-aws-bedrock-text-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-jms-apache-artemis-source-kafka-connector/src/main/docs/examples/CamelJmsapacheartemissourceSourceConnector.properties => camel-aws-bedrock-text-sink-kafka-connector/src/main/docs/examples/CamelAwsbedrocktextsinkSinkConnector.properties} (75%) copy connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3cdcsource/CamelAwss3cdcsourceSourceConnector.java => camel-aws-bedrock-text-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsbedrocktextsink/CamelAwsbedrocktextsinkSinkConnector.java} (79%) create mode 100644 connectors/camel-aws-bedrock-text-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsbedrocktextsink/CamelAwsbedrocktextsinkSinkConnectorConfig.java copy connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3cdcsource/CamelAwss3cdcsourceSourceTask.java => camel-aws-bedrock-text-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsbedrocktextsink/CamelAwsbedrocktextsinkSinkTask.java} (70%) rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector => camel-aws-bedrock-text-sink-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%) rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector => camel-aws-bedrock-text-sink-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-aws-bedrock-text-sink-kafka-connector/src/main/resources/kamelets/aws-bedrock-text-sink.kamelet.yaml delete mode 100644 connectors/camel-aws-s3-cdc-source-kafka-connector/src/generated/descriptors/connector-source.properties delete mode 100644 connectors/camel-aws-s3-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3cdcsource/CamelAwss3cdcsourceSourceConnectorConfig.java rename connectors/{camel-aws-s3-cdc-source-kafka-connector => camel-aws-s3-event-based-source-kafka-connector}/pom.xml (94%) create mode 100644 connectors/camel-aws-s3-event-based-source-kafka-connector/src/generated/descriptors/connector-source.properties rename connectors/{camel-aws-s3-cdc-source-kafka-connector/src/generated/resources/camel-aws-s3-cdc-source-source.json => camel-aws-s3-event-based-source-kafka-connector/src/generated/resources/camel-aws-s3-event-based-source-source.json} (58%) rename connectors/{camel-google-storage-cdc-source-kafka-connector => camel-aws-s3-event-based-source-kafka-connector}/src/main/assembly/package.xml (100%) rename connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/docs/examples/CamelAwss3cdcsourceSourceConnector.properties => camel-aws-s3-event-based-source-kafka-connector/src/main/docs/examples/CamelAwss3eventbasedsourceSourceConnector.properties} (79%) copy connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragecdcsource/CamelGooglestoragecdcsourceSourceConnector.java => camel-aws-s3-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3eventbasedsource/CamelAwss3eventbasedsourceSourceConnector.java} (83%) create mode 100644 connectors/camel-aws-s3-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3eventbasedsource/CamelAwss3eventbasedsourceSourceConnectorConfig.java rename connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragecdcsource/CamelGooglestoragecdcsourceSourceTask.java => camel-aws-s3-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3eventbasedsource/CamelAwss3eventbasedsourceSourceTask.java} (83%) rename connectors/{camel-google-storage-cdc-source-kafka-connector => camel-aws-s3-event-based-source-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%) rename connectors/{camel-google-storage-cdc-source-kafka-connector => camel-aws-s3-event-based-source-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%) rename connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/resources/kamelets/aws-s3-cdc-source.kamelet.yaml => camel-aws-s3-event-based-source-kafka-connector/src/main/resources/kamelets/aws-s3-event-based-source.kamelet.yaml} (90%) delete mode 100644 connectors/camel-azure-storage-blob-cdc-source-kafka-connector/src/generated/descriptors/connector-source.properties delete mode 100644 connectors/camel-azure-storage-blob-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobcdcsource/CamelAzurestorageblobcdcsourceSourceConnectorConfig.java rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector => camel-azure-storage-blob-event-based-source-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-azure-storage-blob-event-based-source-kafka-connector/src/generated/descriptors/connector-source.properties rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector/src/generated/resources/camel-azure-storage-blob-cdc-source-source.json => camel-azure-storage-blob-event-based-source-kafka-connector/src/generated/resources/camel-azure-storage-blob-event-based-source-source.json} (51%) copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-azure-storage-blob-event-based-source-kafka-connector}/src/main/assembly/package.xml (100%) rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector/src/main/docs/examples/CamelAzurestorageblobcdcsourceSourceConnector.properties => camel-azure-storage-blob-event-based-source-kafka-connector/src/main/docs/examples/CamelAzurestorageblobeventbasedsourceSourceConnector.properties} (77%) copy connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragecdcsource/CamelGooglestoragecdcsourceSourceConnector.java => camel-azure-storage-blob-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobeventbasedsource/CamelAzurestorageblobeventbasedsourceSourceConnector.java} (81%) create mode 100644 connectors/camel-azure-storage-blob-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobeventbasedsource/CamelAzurestorageblobeventbasedsourceSourceConnectorConfig.java copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceTask.java => camel-azure-storage-blob-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobeventbasedsource/CamelAzurestorageblobeventbasedsourceSourceTask.java} (82%) copy LICENSE.txt => connectors/camel-azure-storage-blob-event-based-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-azure-storage-blob-event-based-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector/src/main/resources/kamelets/azure-storage-blob-cdc-source.kamelet.yaml => camel-azure-storage-blob-event-based-source-kafka-connector/src/main/resources/kamelets/azure-storage-blob-event-based-source.kamelet.yaml} (97%) copy connectors/{camel-http-source-kafka-connector => camel-counter-source-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-counter-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-counter-source-kafka-connector/src/generated/resources/camel-counter-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-counter-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/docs/examples/CamelKafkaapicurioregistrynotsecuredsourceSourceConnector.properties => camel-counter-source-kafka-connector/src/main/docs/examples/CamelCountersourceSourceConnector.properties} (70%) rename connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3cdcsource/CamelAwss3cdcsourceSourceConnector.java => camel-counter-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/countersource/CamelCountersourceSourceConnector.java} (83%) create mode 100644 connectors/camel-counter-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/countersource/CamelCountersourceSourceConnectorConfig.java copy connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3cdcsource/CamelAwss3cdcsourceSourceTask.java => camel-counter-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/countersource/CamelCountersourceSourceTask.java} (85%) copy LICENSE.txt => connectors/camel-counter-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-counter-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-timer-source-kafka-connector/src/main/resources/kamelets/timer-source.kamelet.yaml => camel-counter-source-kafka-connector/src/main/resources/kamelets/counter-source.kamelet.yaml} (83%) delete mode 100644 connectors/camel-google-storage-cdc-source-kafka-connector/src/generated/descriptors/connector-source.properties delete mode 100644 connectors/camel-google-storage-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragecdcsource/CamelGooglestoragecdcsourceSourceConnectorConfig.java rename connectors/{camel-google-storage-cdc-source-kafka-connector => camel-google-storage-event-based-source-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-google-storage-event-based-source-kafka-connector/src/generated/descriptors/connector-source.properties rename connectors/{camel-google-storage-cdc-source-kafka-connector/src/generated/resources/camel-google-storage-cdc-source-source.json => camel-google-storage-event-based-source-kafka-connector/src/generated/resources/camel-google-storage-event-based-source-source.json} (54%) copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-google-storage-event-based-source-kafka-connector}/src/main/assembly/package.xml (100%) rename connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/docs/examples/CamelGooglestoragecdcsourceSourceConnector.properties => camel-google-storage-event-based-source-kafka-connector/src/main/docs/examples/CamelGooglestorageeventbasedsourceSourceConnector.properties} (78%) copy connectors/{camel-azure-storage-blob-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobcdcsource/CamelAzurestorageblobcdcsourceSourceConnector.java => camel-google-storage-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorageeventbasedsource/CamelGooglestorageeventbasedsourceSourceConnector.java} (82%) create mode 100644 connectors/camel-google-storage-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorageeventbasedsource/CamelGooglestorageeventbasedsourceSourceConnectorConfig.java copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceTask.java => camel-google-storage-event-based-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestorageeventbasedsource/CamelGooglestorageeventbasedsourceSourceTask.java} (82%) copy LICENSE.txt => connectors/camel-google-storage-event-based-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-google-storage-event-based-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) rename connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/resources/kamelets/google-storage-cdc-source.kamelet.yaml => camel-google-storage-event-based-source-kafka-connector/src/main/resources/kamelets/google-storage-event-based-source.kamelet.yaml} (96%) copy connectors/{camel-jms-apache-artemis-sink-kafka-connector => camel-jms-pooled-apache-artemis-sink-kafka-connector}/pom.xml (89%) create mode 100644 connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/generated/resources/camel-jms-pooled-apache-artemis-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-jms-pooled-apache-artemis-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-jms-apache-artemis-source-kafka-connector/src/main/docs/examples/CamelJmsapacheartemissourceSourceConnector.properties => camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/docs/examples/CamelJmspooledapacheartemissinkSinkConnector.properties} (74%) copy connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragecdcsource/CamelGooglestoragecdcsourceSourceConnector.java => camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmspooledapacheartemissink/CamelJmspooledapacheartemissinkSinkConnector.java} (77%) create mode 100644 connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmspooledapacheartemissink/CamelJmspooledapacheartemissinkSinkConnectorConfig.java rename connectors/{camel-aws-s3-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3cdcsource/CamelAwss3cdcsourceSourceTask.java => camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmspooledapacheartemissink/CamelJmspooledapacheartemissinkSinkTask.java} (68%) copy LICENSE.txt => connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-jms-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-sink.kamelet.yaml => camel-jms-pooled-apache-artemis-sink-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-sink.kamelet.yaml} (93%) copy connectors/{camel-jms-apache-artemis-sink-kafka-connector => camel-jms-pooled-apache-artemis-source-kafka-connector}/pom.xml (89%) create mode 100644 connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/generated/resources/camel-jms-pooled-apache-artemis-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-jms-pooled-apache-artemis-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-jms-apache-artemis-source-kafka-connector/src/main/docs/examples/CamelJmsapacheartemissourceSourceConnector.properties => camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/docs/examples/CamelJmspooledapacheartemissourceSourceConnector.properties} (79%) copy connectors/{camel-azure-storage-blob-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobcdcsource/CamelAzurestorageblobcdcsourceSourceConnector.java => camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmspooledapacheartemissource/CamelJmspooledapacheartemissourceSourceConnector.java} (82%) create mode 100644 connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmspooledapacheartemissource/CamelJmspooledapacheartemissourceSourceConnectorConfig.java rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobcdcsource/CamelAzurestorageblobcdcsourceSourceTask.java => camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmspooledapacheartemissource/CamelJmspooledapacheartemissourceSourceTask.java} (81%) copy LICENSE.txt => connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-jms-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-apache-artemis-source.kamelet.yaml => camel-jms-pooled-apache-artemis-source-kafka-connector/src/main/resources/kamelets/jms-pooled-apache-artemis-source.kamelet.yaml} (93%) delete mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/generated/descriptors/connector-source.properties delete mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/generated/resources/camel-kafka-apicurio-registry-not-secured-source-source.json delete mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/assembly/package.xml delete mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceConnectorConfig.java delete mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt delete mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt copy connectors/{camel-kafka-batch-apicurio-registry-not-secured-source-kafka-connector => camel-kafka-batch-apicurio-registry-source-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/src/generated/resources/camel-kafka-batch-apicurio-registry-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-kafka-batch-apicurio-registry-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/docs/examples/CamelKafkaapicurioregistrynotsecuredsourceSourceConnector.properties => camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/docs/examples/CamelKafkabatchapicurioregistrysourceSourceConnector.properties} (53%) copy connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragecdcsource/CamelGooglestoragecdcsourceSourceConnector.java => camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkabatchapicurioregistrysource/CamelKafkabatchapicurioregistrysourceSourceConnector.java} (81%) create mode 100644 connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkabatchapicurioregistrysource/CamelKafkabatchapicurioregistrysourceSourceConnectorConfig.java copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceTask.java => camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkabatchapicurioregistrysource/CamelKafkabatchapicurioregistrysourceSourceTask.java} (82%) copy LICENSE.txt => connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-kafka-batch-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/kamelets/kafka-batch-apicurio-registry-not-secured-source.kamelet.yaml => camel-kafka-batch-apicurio-registry-source-kafka-connector/src/main/resources/kamelets/kafka-batch-apicurio-registry-source.kamelet.yaml} (75%) copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector => camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector}/pom.xml (89%) create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/generated/resources/camel-kafka-not-secured-apicurio-registry-json-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/docs/examples/CamelKafkaapicurioregistrynotsecuredsourceSourceConnector.properties => camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/main/docs/examples/CamelKafkanotsecuredapicurioregistryjsonsourceSourceConnector.properties} (50%) rename connectors/{camel-azure-storage-blob-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobcdcsource/CamelAzurestorageblobcdcsourceSourceConnector.java => camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistryjsonsource/CamelKafkanotsecuredapicurioregistryjsonsourceSourceConnector.java} (80%) create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistryjsonsource/CamelKafkanotsecuredapicurioregistryjsonsourceSourceConnectorConfig.java copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceTask.java => camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistryjsonsource/CamelKafkanotsecuredapicurioregistryjsonsourceSourceTask.java} (81%) copy LICENSE.txt => connectors/camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml => camel-kafka-not-secured-apicurio-registry-json-source-kafka-connector/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-json-source.kamelet.yaml} (73%) copy connectors/{camel-kafka-apicurio-registry-not-secured-sink-kafka-connector => camel-kafka-not-secured-apicurio-registry-sink-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/generated/resources/camel-kafka-not-secured-apicurio-registry-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-kafka-not-secured-apicurio-registry-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/docs/examples/CamelKafkaapicurioregistrynotsecuredsourceSourceConnector.properties => camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/main/docs/examples/CamelKafkanotsecuredapicurioregistrysinkSinkConnector.properties} (50%) rename connectors/{camel-google-storage-cdc-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragecdcsource/CamelGooglestoragecdcsourceSourceConnector.java => camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistrysink/CamelKafkanotsecuredapicurioregistrysinkSinkConnector.java} (75%) create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistrysink/CamelKafkanotsecuredapicurioregistrysinkSinkConnectorConfig.java copy connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceTask.java => camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistrysink/CamelKafkanotsecuredapicurioregistrysinkSinkTask.java} (66%) copy LICENSE.txt => connectors/camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml => camel-kafka-not-secured-apicurio-registry-sink-kafka-connector/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-sink.kamelet.yaml} (72%) rename connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector => camel-kafka-not-secured-apicurio-registry-source-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/generated/resources/camel-kafka-not-secured-apicurio-registry-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-kafka-not-secured-apicurio-registry-source-kafka-connector}/src/main/assembly/package.xml (100%) rename connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/docs/examples/CamelKafkaapicurioregistrynotsecuredsourceSourceConnector.properties => camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/main/docs/examples/CamelKafkanotsecuredapicurioregistrysourceSourceConnector.properties} (53%) rename connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceConnector.java => camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistrysource/CamelKafkanotsecuredapicurioregistrysourceSourceConnector.java} (83%) create mode 100644 connectors/camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistrysource/CamelKafkanotsecuredapicurioregistrysourceSourceConnectorConfig.java rename connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceTask.java => camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkanotsecuredapicurioregistrysource/CamelKafkanotsecuredapicurioregistrysourceSourceTask.java} (84%) copy LICENSE.txt => connectors/camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) rename connectors/{camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml => camel-kafka-not-secured-apicurio-registry-source-kafka-connector/src/main/resources/kamelets/kafka-not-secured-apicurio-registry-source.kamelet.yaml} (76%) create mode 100644 tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/common/FixedDispatchRouterContainer.java