This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
from 8a75bf93e0 Updated CHANGELOG.md new 35151df4b2 Fixed naming issues in release-utils/scripts/upload-source.sh new 3d0ab78cdc Updated to kafka 3.5.1 new e835377697 Updated to camel 4.3.0 new 85b13dbc93 chore: regen. The 4 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: .../connectors/camel-aws-ddb-sink-sink.json | 2 +- .../connectors/camel-aws-s3-sink-sink.json | 7 + .../connectors/camel-aws-s3-source-source.json | 14 ++ .../camel-aws-s3-streaming-upload-sink-sink.json | 7 + .../connectors/camel-aws-sqs-fifo-sink-sink.json | 2 +- .../camel-aws-timestream-query-sink-sink.json | 51 ++++++ .../resources/connectors/camel-aws2-iam-sink.json | 94 ++++++++++- .../resources/connectors/camel-aws2-kms-sink.json | 94 ++++++++++- .../camel-azure-storage-blob-append-sink-sink.json | 38 +++++ .../connectors/camel-coffee-source-source.json | 20 +++ .../resources/connectors/camel-cxf-source.json | 4 +- .../resources/connectors/camel-cxfrs-source.json | 4 +- .../resources/connectors/camel-file-sink.json | 21 +++ .../resources/connectors/camel-file-source.json | 13 +- .../connectors/camel-google-sheets-sink-sink.json | 83 ++++++++++ .../camel-google-sheets-source-source.json | 16 +- .../resources/connectors/camel-hdfs-source.json | 4 +- .../resources/connectors/camel-https-sink.json | 18 ++ .../connectors/camel-jms-ibm-mq-sink-sink.json | 2 +- .../connectors/camel-jms-ibm-mq-source-source.json | 2 +- ...ka-apicurio-registry-not-secured-sink-sink.json | 45 +++++ ...picurio-registry-not-secured-source-source.json | 86 ++++++++++ ...amel-kafka-azure-schema-registry-sink-sink.json | 64 +++++++ ...-kafka-azure-schema-registry-source-source.json | 105 ++++++++++++ .../connectors/camel-kafka-ssl-sink-sink.json | 7 + .../connectors/camel-kafka-ssl-source-source.json | 7 + .../connectors/camel-mariadb-sink-sink.json | 2 +- .../connectors/camel-mariadb-source-source.json | 2 +- .../connectors/camel-mysql-sink-sink.json | 2 +- .../connectors/camel-mysql-source-source.json | 2 +- .../connectors/camel-netty-http-source.json | 4 +- .../resources/connectors/camel-netty-source.json | 4 +- .../camel-oracle-database-sink-sink.json | 2 +- .../camel-oracle-database-source-source.json | 2 +- .../resources/connectors/camel-sjms2-source.json | 4 +- .../connectors/camel-splunk-source-source.json | 4 +- .../connectors/camel-sqlserver-sink-sink.json | 2 +- .../connectors/camel-sqlserver-source-source.json | 2 +- .../resources/descriptors/connectors.properties | 8 + .../kamelets/aws-cloudtrail-source.kamelet.yaml | 6 +- .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 32 ++-- .../camel-aws-ddb-sink-kafka-connector/pom.xml | 10 +- .../resources/camel-aws-ddb-sink-sink.json | 2 +- .../resources/kamelets/aws-ddb-sink.kamelet.yaml | 58 +++++-- .../kamelets/aws-ddb-streams-source.kamelet.yaml | 6 +- .../resources/kamelets/aws-ec2-sink.kamelet.yaml | 10 +- .../kamelets/aws-eventbridge-sink.kamelet.yaml | 18 +- .../aws-kinesis-firehose-sink.kamelet.yaml | 6 +- .../kamelets/aws-kinesis-sink.kamelet.yaml | 16 +- .../pom.xml | 10 +- .../kamelets/aws-kinesis-source.kamelet.yaml | 10 +- .../kamelets/aws-lambda-sink.kamelet.yaml | 6 +- .../pom.xml | 20 +-- .../kamelets/aws-redshift-sink.kamelet.yaml | 7 +- .../pom.xml | 20 +-- .../kamelets/aws-redshift-source.kamelet.yaml | 7 +- .../kamelets/aws-s3-cdc-source.kamelet.yaml | 15 +- .../resources/camel-aws-s3-sink-sink.json | 7 + .../CamelAwss3sinkSinkConnectorConfig.java | 4 + .../resources/kamelets/aws-s3-sink.kamelet.yaml | 22 +-- .../camel-aws-s3-source-kafka-connector/pom.xml | 10 +- .../resources/camel-aws-s3-source-source.json | 14 ++ .../CamelAwss3sourceSourceConnectorConfig.java | 8 + .../resources/kamelets/aws-s3-source.kamelet.yaml | 79 ++++++++- .../camel-aws-s3-streaming-upload-sink-sink.json | 7 + ...wss3streaminguploadsinkSinkConnectorConfig.java | 4 + .../aws-s3-streaming-upload-sink.kamelet.yaml | 18 +- .../kamelets/aws-secrets-manager-sink.kamelet.yaml | 11 +- .../resources/kamelets/aws-ses-sink.kamelet.yaml | 19 +-- .../kamelets/aws-sns-fifo-sink.kamelet.yaml | 24 +-- .../resources/kamelets/aws-sns-sink.kamelet.yaml | 11 +- .../kamelets/aws-sqs-batch-sink.kamelet.yaml | 7 +- .../resources/camel-aws-sqs-fifo-sink-sink.json | 2 +- .../kamelets/aws-sqs-fifo-sink.kamelet.yaml | 17 +- .../resources/kamelets/aws-sqs-sink.kamelet.yaml | 7 +- .../camel-aws-sqs-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/aws-sqs-source.kamelet.yaml | 70 +++++++- .../pom.xml | 14 +- .../descriptors/connector-sink.properties | 1 + .../camel-aws-timestream-query-sink-sink.json | 51 ++++++ .../src/main/assembly/package.xml | 0 ...AwstimestreamquerysinkSinkConnector.properties} | 16 +- .../CamelAwstimestreamquerysinkSinkConnector.java | 29 ++-- ...lAwstimestreamquerysinkSinkConnectorConfig.java | 68 ++++++++ .../CamelAwstimestreamquerysinkSinkTask.java | 29 ++-- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../aws-timestream-query-sink.kamelet.yaml | 112 +++++++++++++ .../generated/resources/camel-aws2-iam-sink.json | 94 ++++++++++- .../aws2iam/CamelAws2iamSinkConnectorConfig.java | 4 +- .../generated/resources/camel-aws2-kms-sink.json | 94 ++++++++++- .../aws2kms/CamelAws2kmsSinkConnectorConfig.java | 4 +- .../kamelets/azure-cosmosdb-sink.kamelet.yaml | 7 +- .../kamelets/azure-cosmosdb-source.kamelet.yaml | 7 +- .../kamelets/azure-eventhubs-sink.kamelet.yaml | 7 +- .../kamelets/azure-eventhubs-source.kamelet.yaml | 4 +- .../kamelets/azure-functions-sink.kamelet.yaml | 7 +- .../kamelets/azure-servicebus-sink.kamelet.yaml | 3 +- .../kamelets/azure-servicebus-source.kamelet.yaml | 5 +- .../pom.xml | 14 +- .../descriptors/connector-sink.properties | 1 + .../camel-azure-storage-blob-append-sink-sink.json | 38 +++++ .../src/main/assembly/package.xml | 0 ...estorageblobappendsinkSinkConnector.properties} | 18 +- ...melAzurestorageblobappendsinkSinkConnector.java | 29 ++-- ...restorageblobappendsinkSinkConnectorConfig.java | 60 +++++++ .../CamelAzurestorageblobappendsinkSinkTask.java | 29 ++-- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../azure-storage-blob-append-sink.kamelet.yaml} | 18 +- .../azure-storage-blob-cdc-source.kamelet.yaml | 13 +- .../pom.xml | 10 -- ...ure-storage-blob-changefeed-source.kamelet.yaml | 42 +++-- .../kamelets/azure-storage-blob-sink.kamelet.yaml | 9 +- .../pom.xml | 10 +- .../azure-storage-blob-source.kamelet.yaml | 76 ++++++++- .../pom.xml | 10 +- .../azure-storage-datalake-sink.kamelet.yaml | 13 +- .../pom.xml | 10 +- .../azure-storage-datalake-source.kamelet.yaml | 7 +- .../kamelets/azure-storage-queue-sink.kamelet.yaml | 7 +- .../pom.xml | 10 +- .../azure-storage-queue-source.kamelet.yaml | 5 +- .../resources/kamelets/beer-source.kamelet.yaml | 4 +- .../resources/kamelets/bitcoin-source.kamelet.yaml | 2 +- .../resources/kamelets/cassandra-sink.kamelet.yaml | 4 +- .../kamelets/cassandra-source.kamelet.yaml | 3 +- .../main/resources/kamelets/ceph-sink.kamelet.yaml | 11 +- .../resources/kamelets/ceph-source.kamelet.yaml | 8 +- .../kamelets/chuck-norris-source.kamelet.yaml | 6 +- .../pom.xml | 10 +- .../descriptors/connector-source.properties | 1 + .../resources/camel-coffee-source-source.json | 20 +++ .../src/main/assembly/package.xml | 0 .../CamelCoffeesourceSourceConnector.properties} | 12 +- .../CamelCoffeesourceSourceConnector.java | 27 +-- .../CamelCoffeesourceSourceConnectorConfig.java | 48 ++++++ .../coffeesource/CamelCoffeesourceSourceTask.java | 29 ++-- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../resources/kamelets/coffee-source.kamelet.yaml} | 18 +- .../resources/kamelets/couchbase-sink.kamelet.yaml | 4 +- .../resources/kamelets/cron-source.kamelet.yaml | 4 +- .../src/generated/resources/camel-cxf-source.json | 4 +- .../cxf/CamelCxfSourceConnectorConfig.java | 4 +- .../generated/resources/camel-cxfrs-source.json | 4 +- .../cxfrs/CamelCxfrsSourceConnectorConfig.java | 4 +- .../resources/kamelets/dropbox-sink.kamelet.yaml | 7 +- .../resources/kamelets/dropbox-source.kamelet.yaml | 5 +- .../kamelets/earthquake-source.kamelet.yaml | 24 +-- .../kamelets/elasticsearch-index-sink.kamelet.yaml | 12 +- .../elasticsearch-search-source.kamelet.yaml | 6 +- .../main/resources/kamelets/exec-sink.kamelet.yaml | 8 +- .../main/resources/kamelets/fhir-sink.kamelet.yaml | 16 +- .../resources/kamelets/fhir-source.kamelet.yaml | 8 +- .../src/generated/resources/camel-file-sink.json | 21 +++ .../src/generated/resources/camel-file-source.json | 13 +- .../file/CamelFileSinkConnectorConfig.java | 4 + .../file/CamelFileSourceConnectorConfig.java | 10 +- .../kamelets/file-watch-source.kamelet.yaml | 2 +- .../main/resources/kamelets/ftp-sink.kamelet.yaml | 10 +- .../resources/kamelets/ftp-source.kamelet.yaml | 15 +- .../main/resources/kamelets/ftps-sink.kamelet.yaml | 10 +- .../resources/kamelets/ftps-source.kamelet.yaml | 15 +- .../kamelets/github-commit-source.kamelet.yaml | 3 +- .../kamelets/github-event-source.kamelet.yaml | 3 +- .../github-pullrequest-comment-source.kamelet.yaml | 3 +- .../github-pullrequest-source.kamelet.yaml | 3 +- .../kamelets/github-tag-source.kamelet.yaml | 3 +- .../kamelets/google-bigquery-sink.kamelet.yaml | 2 +- .../kamelets/google-calendar-source.kamelet.yaml | 8 +- .../kamelets/google-functions-sink.kamelet.yaml | 2 +- .../kamelets/google-mail-source.kamelet.yaml | 7 +- .../kamelets/google-pubsub-sink.kamelet.yaml | 2 +- .../kamelets/google-pubsub-source.kamelet.yaml | 3 +- .../pom.xml | 24 +-- .../descriptors/connector-sink.properties | 1 + .../resources/camel-google-sheets-sink-sink.json | 83 ++++++++++ .../src/main/assembly/package.xml | 0 .../CamelGooglesheetssinkSinkConnector.properties} | 24 +-- .../CamelGooglesheetssinkSinkConnector.java | 27 +-- .../CamelGooglesheetssinkSinkConnectorConfig.java | 88 ++++++++++ .../CamelGooglesheetssinkSinkTask.java | 29 ++-- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kamelets/google-sheets-sink.kamelet.yaml | 184 +++++++++++++++++++++ .../pom.xml | 4 + .../camel-google-sheets-source-source.json | 16 +- ...melGooglesheetssourceSourceConnectorConfig.java | 10 +- .../kamelets/google-sheets-source.kamelet.yaml | 86 ++++++++-- .../google-storage-cdc-source.kamelet.yaml | 10 +- .../kamelets/google-storage-sink.kamelet.yaml | 9 +- .../kamelets/google-storage-source.kamelet.yaml | 59 ++++++- .../resources/kamelets/graphql-sink.kamelet.yaml | 3 +- .../src/generated/resources/camel-hdfs-source.json | 4 +- .../hdfs/CamelHdfsSourceConnectorConfig.java | 4 +- .../kamelets/http-secured-sink.kamelet.yaml | 8 +- .../kamelets/http-secured-source.kamelet.yaml | 7 +- .../main/resources/kamelets/http-sink.kamelet.yaml | 6 +- .../resources/kamelets/http-source.kamelet.yaml | 4 +- .../src/generated/resources/camel-https-sink.json | 18 ++ .../https/CamelHttpsSinkConnectorConfig.java | 12 ++ .../kamelets/infinispan-sink.kamelet.yaml | 12 +- .../kamelets/infinispan-source.kamelet.yaml | 20 +-- .../kamelets/jira-add-comment-sink.kamelet.yaml | 7 +- .../kamelets/jira-add-issue-sink.kamelet.yaml | 19 +-- .../kamelets/jira-oauth-source.kamelet.yaml | 8 +- .../resources/kamelets/jira-source.kamelet.yaml | 5 +- .../jira-transition-issue-sink.kamelet.yaml | 9 +- .../kamelets/jira-update-issue-sink.kamelet.yaml | 19 +-- .../kamelets/jms-amqp-10-sink.kamelet.yaml | 2 +- .../kamelets/jms-amqp-10-source.kamelet.yaml | 2 +- .../pom.xml | 10 +- .../kamelets/jms-apache-artemis-sink.kamelet.yaml | 4 +- .../pom.xml | 10 +- .../jms-apache-artemis-source.kamelet.yaml | 4 +- .../resources/camel-jms-ibm-mq-sink-sink.json | 2 +- .../kamelets/jms-ibm-mq-sink.kamelet.yaml | 5 +- .../resources/camel-jms-ibm-mq-source-source.json | 2 +- .../kamelets/jms-ibm-mq-source.kamelet.yaml | 5 +- .../pom.xml | 16 +- .../descriptors/connector-sink.properties | 1 + ...ka-apicurio-registry-not-secured-sink-sink.json | 45 +++++ .../src/main/assembly/package.xml | 0 ...registrynotsecuredsinkSinkConnector.properties} | 20 +-- ...picurioregistrynotsecuredsinkSinkConnector.java | 29 ++-- ...oregistrynotsecuredsinkSinkConnectorConfig.java | 64 +++++++ ...afkaapicurioregistrynotsecuredsinkSinkTask.java | 38 +++++ .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...picurio-registry-not-secured-sink.kamelet.yaml} | 53 +++--- .../pom.xml | 21 ++- .../descriptors/connector-source.properties | 1 + ...picurio-registry-not-secured-source-source.json | 86 ++++++++++ .../src/main/assembly/package.xml | 0 ...strynotsecuredsourceSourceConnector.properties} | 18 +- ...rioregistrynotsecuredsourceSourceConnector.java | 36 ++++ ...istrynotsecuredsourceSourceConnectorConfig.java | 88 ++++++++++ ...apicurioregistrynotsecuredsourceSourceTask.java | 38 +++++ .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...curio-registry-not-secured-source.kamelet.yaml} | 37 ++++- .../pom.xml | 36 ++-- .../descriptors/connector-sink.properties | 1 + ...amel-kafka-azure-schema-registry-sink-sink.json | 64 +++++++ .../src/main/assembly/package.xml | 0 ...zureschemaregistrysinkSinkConnector.properties} | 22 +-- ...lKafkaazureschemaregistrysinkSinkConnector.java | 29 ++-- ...azureschemaregistrysinkSinkConnectorConfig.java | 76 +++++++++ .../CamelKafkaazureschemaregistrysinkSinkTask.java | 36 ++++ .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kafka-azure-schema-registry-sink.kamelet.yaml} | 57 +++++-- .../pom.xml | 36 ++-- .../descriptors/connector-source.properties | 1 + ...-kafka-azure-schema-registry-source-source.json | 105 ++++++++++++ .../src/main/assembly/package.xml | 0 ...schemaregistrysourceSourceConnector.properties} | 20 +-- ...kaazureschemaregistrysourceSourceConnector.java | 29 ++-- ...eschemaregistrysourceSourceConnectorConfig.java | 100 +++++++++++ ...elKafkaazureschemaregistrysourceSourceTask.java | 38 +++++ .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 ...afka-azure-schema-registry-source.kamelet.yaml} | 63 ++++--- .../pom.xml | 10 +- .../kamelets/kafka-not-secured-sink.kamelet.yaml | 12 +- .../pom.xml | 10 +- .../kamelets/kafka-not-secured-source.kamelet.yaml | 10 +- .../kamelets/kafka-scram-sink.kamelet.yaml | 11 +- .../pom.xml | 10 +- .../kamelets/kafka-scram-source.kamelet.yaml | 8 +- .../resources/kamelets/kafka-sink.kamelet.yaml | 11 +- .../camel-kafka-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/kafka-source.kamelet.yaml | 8 +- .../resources/camel-kafka-ssl-sink-sink.json | 7 + .../CamelKafkasslsinkSinkConnectorConfig.java | 4 + .../resources/kamelets/kafka-ssl-sink.kamelet.yaml | 18 +- .../camel-kafka-ssl-source-kafka-connector/pom.xml | 10 +- .../resources/camel-kafka-ssl-source-source.json | 7 + .../CamelKafkasslsourceSourceConnectorConfig.java | 4 + .../kamelets/kafka-ssl-source.kamelet.yaml | 15 +- .../kubernetes-namespaces-source.kamelet.yaml | 3 +- .../kamelets/kubernetes-nodes-source.kamelet.yaml | 3 +- .../kamelets/kubernetes-pods-source.kamelet.yaml | 3 +- .../main/resources/kamelets/log-sink.kamelet.yaml | 50 ++---- .../kamelets/mail-imap-source.kamelet.yaml | 13 +- .../main/resources/kamelets/mail-sink.kamelet.yaml | 13 +- .../camel-mariadb-sink-kafka-connector/pom.xml | 10 +- .../resources/camel-mariadb-sink-sink.json | 2 +- .../resources/kamelets/mariadb-sink.kamelet.yaml | 7 +- .../camel-mariadb-source-kafka-connector/pom.xml | 10 +- .../resources/camel-mariadb-source-source.json | 2 +- .../resources/kamelets/mariadb-source.kamelet.yaml | 7 +- .../resources/kamelets/minio-sink.kamelet.yaml | 11 +- .../resources/kamelets/minio-source.kamelet.yaml | 6 +- .../pom.xml | 10 +- .../mongodb-changes-stream-source.kamelet.yaml | 7 +- .../camel-mongodb-sink-kafka-connector/pom.xml | 10 +- .../resources/kamelets/mongodb-sink.kamelet.yaml | 12 +- .../camel-mongodb-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/mongodb-source.kamelet.yaml | 8 +- .../main/resources/kamelets/mqtt-sink.kamelet.yaml | 3 +- .../resources/kamelets/mqtt-source.kamelet.yaml | 3 +- .../resources/kamelets/mqtt5-sink.kamelet.yaml | 3 +- .../resources/kamelets/mqtt5-source.kamelet.yaml | 3 +- .../camel-mysql-sink-kafka-connector/pom.xml | 10 +- .../generated/resources/camel-mysql-sink-sink.json | 2 +- .../resources/kamelets/mysql-sink.kamelet.yaml | 7 +- .../camel-mysql-source-kafka-connector/pom.xml | 10 +- .../resources/camel-mysql-source-source.json | 2 +- .../resources/kamelets/mysql-source.kamelet.yaml | 7 +- .../main/resources/kamelets/nats-sink.kamelet.yaml | 3 +- .../resources/kamelets/nats-source.kamelet.yaml | 3 +- .../resources/camel-netty-http-source.json | 4 +- .../CamelNettyhttpSourceConnectorConfig.java | 4 +- .../generated/resources/camel-netty-source.json | 4 +- .../netty/CamelNettySourceConnectorConfig.java | 4 +- .../kamelets/opensearch-index-sink.kamelet.yaml | 12 +- .../kamelets/opensearch-search-source.kamelet.yaml | 6 +- .../pom.xml | 10 +- .../resources/camel-oracle-database-sink-sink.json | 2 +- .../kamelets/oracle-database-sink.kamelet.yaml | 7 +- .../pom.xml | 10 +- .../camel-oracle-database-source-source.json | 2 +- .../kamelets/oracle-database-source.kamelet.yaml | 7 +- .../camel-postgresql-sink-kafka-connector/pom.xml | 18 +- .../kamelets/postgresql-sink.kamelet.yaml | 7 +- .../pom.xml | 18 +- .../kamelets/postgresql-source.kamelet.yaml | 7 +- .../resources/kamelets/pulsar-sink.kamelet.yaml | 22 +-- .../resources/kamelets/pulsar-source.kamelet.yaml | 8 +- .../resources/kamelets/redis-sink.kamelet.yaml | 22 +-- .../resources/kamelets/redis-source.kamelet.yaml | 2 +- .../kamelets/rest-openapi-sink.kamelet.yaml | 2 +- .../salesforce-composite-upsert-sink.kamelet.yaml | 4 +- .../kamelets/salesforce-create-sink.kamelet.yaml | 4 +- .../kamelets/salesforce-delete-sink.kamelet.yaml | 12 +- .../kamelets/salesforce-source.kamelet.yaml | 8 +- .../kamelets/salesforce-update-sink.kamelet.yaml | 8 +- .../main/resources/kamelets/scp-sink.kamelet.yaml | 4 +- .../main/resources/kamelets/sftp-sink.kamelet.yaml | 11 +- .../resources/kamelets/sftp-source.kamelet.yaml | 17 +- .../generated/resources/camel-sjms2-source.json | 4 +- .../sjms2/CamelSjms2SourceConnectorConfig.java | 4 +- .../resources/kamelets/slack-sink.kamelet.yaml | 3 +- .../resources/kamelets/slack-source.kamelet.yaml | 3 +- .../kamelets/splunk-hec-sink.kamelet.yaml | 7 +- .../resources/kamelets/splunk-sink.kamelet.yaml | 3 +- .../resources/camel-splunk-source-source.json | 4 +- .../CamelSplunksourceSourceConnector.properties | 2 + .../CamelSplunksourceSourceConnectorConfig.java | 2 +- .../resources/kamelets/splunk-source.kamelet.yaml | 8 +- .../camel-sqlserver-sink-kafka-connector/pom.xml | 10 +- .../resources/camel-sqlserver-sink-sink.json | 2 +- .../resources/kamelets/sqlserver-sink.kamelet.yaml | 9 +- .../camel-sqlserver-source-kafka-connector/pom.xml | 10 +- .../resources/camel-sqlserver-source-source.json | 2 +- .../kamelets/sqlserver-source.kamelet.yaml | 9 +- .../main/resources/kamelets/ssh-sink.kamelet.yaml | 3 +- .../resources/kamelets/ssh-source.kamelet.yaml | 5 +- .../resources/kamelets/telegram-sink.kamelet.yaml | 21 ++- .../kamelets/telegram-source.kamelet.yaml | 7 +- .../resources/kamelets/timer-source.kamelet.yaml | 6 +- .../twitter-directmessage-source.kamelet.yaml | 6 +- .../kamelets/twitter-search-source.kamelet.yaml | 6 +- .../kamelets/twitter-timeline-source.kamelet.yaml | 6 +- .../resources/kamelets/webhook-source.kamelet.yaml | 2 +- .../resources/kamelets/wttrin-source.kamelet.yaml | 2 +- connectors/pom.xml | 8 + docs/modules/ROOT/nav.adoc | 16 ++ .../pages/contributor-guide/release-guide.adoc | 5 +- docs/modules/ROOT/pages/reference/index.adoc | 10 +- parent/pom.xml | 9 +- pom.xml | 2 +- release-utils/scripts/upload-source.sh | 7 +- .../aws/v2/clients/AWSSQSClient.java | 13 +- .../aws/v2/lambda/sink/CamelSinkLambdaITCase.java | 22 +-- .../aws/v2/sns/sink/CamelSinkAWSSNSITCase.java | 4 +- .../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 2 +- ...CloudWatchLocalContainerServiceWithTimeout.java | 2 +- ...WSDynamodbLocalContainerServiceWithTimeout.java | 2 +- .../AWSEC2LocalContainerServiceWithTimeout.java | 2 +- ...ventBridgeLocalContainerServiceWithTimeout.java | 2 +- .../AWSIAMLocalContainerServiceWithTimeout.java | 2 +- .../AWSKMSLocalContainerServiceWithTimeout.java | 2 +- ...AWSKinesisLocalContainerServiceWithTimeout.java | 2 +- .../AWSLambdaLocalContainerServiceWithTimeout.java | 2 +- .../AWSS3LocalContainerServiceWithTimeout.java | 2 +- .../AWSSNSLocalContainerServiceWithTimeout.java | 2 +- .../AWSSQSLocalContainerServiceWithTimeout.java | 2 +- .../AWSSTSLocalContainerServiceWithTimeout.java | 2 +- .../kafka/ByteArrayProducerPropertyFactory.java | 52 ++++++ .../services/kafka/EmbeddedKafkaService.java | 3 +- .../DefaultKafkaConnectPropertyFactory.java | 3 +- .../services/kafkaconnect/KafkaConnectRunner.java | 7 +- .../hdfs/sink/CamelSinkHDFSITCase.java | 2 + tooling/pom.xml | 2 +- 397 files changed, 4442 insertions(+), 1625 deletions(-) create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-timestream-query-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-blob-append-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-coffee-source-source.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-sheets-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-apicurio-registry-not-secured-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-apicurio-registry-not-secured-source-source.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-azure-schema-registry-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kafka-azure-schema-registry-source-source.json copy connectors/{camel-google-sheets-source-kafka-connector => camel-aws-timestream-query-sink-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-aws-timestream-query-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-aws-timestream-query-sink-kafka-connector/src/generated/resources/camel-aws-timestream-query-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-aws-timestream-query-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-splunk-source-kafka-connector/src/main/docs/examples/CamelSplunksourceSourceConnector.properties => camel-aws-timestream-query-sink-kafka-connector/src/main/docs/examples/CamelAwstimestreamquerysinkSinkConnector.properties} (70%) copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-aws-timestream-query-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awstimestreamquerysink/CamelAwstimestreamquerysinkSinkConnector.java (52%) create mode 100644 connectors/camel-aws-timestream-query-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awstimestreamquerysink/CamelAwstimestreamquerysinkSinkConnectorConfig.java copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-aws-timestream-query-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awstimestreamquerysink/CamelAwstimestreamquerysinkSinkTask.java (50%) copy LICENSE.txt => connectors/camel-aws-timestream-query-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-aws-timestream-query-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-aws-timestream-query-sink-kafka-connector/src/main/resources/kamelets/aws-timestream-query-sink.kamelet.yaml copy connectors/{camel-google-sheets-source-kafka-connector => camel-azure-storage-blob-append-sink-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-azure-storage-blob-append-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-azure-storage-blob-append-sink-kafka-connector/src/generated/resources/camel-azure-storage-blob-append-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-azure-storage-blob-append-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-splunk-source-kafka-connector/src/main/docs/examples/CamelSplunksourceSourceConnector.properties => camel-azure-storage-blob-append-sink-kafka-connector/src/main/docs/examples/CamelAzurestorageblobappendsinkSinkConnector.properties} (70%) copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-azure-storage-blob-append-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobappendsink/CamelAzurestorageblobappendsinkSinkConnector.java (51%) create mode 100644 connectors/camel-azure-storage-blob-append-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobappendsink/CamelAzurestorageblobappendsinkSinkConnectorConfig.java copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-azure-storage-blob-append-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobappendsink/CamelAzurestorageblobappendsinkSinkTask.java (50%) copy LICENSE.txt => connectors/camel-azure-storage-blob-append-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-azure-storage-blob-append-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-azure-storage-blob-sink-kafka-connector/src/main/resources/kamelets/azure-storage-blob-sink.kamelet.yaml => camel-azure-storage-blob-append-sink-kafka-connector/src/main/resources/kamelets/azure-storage-blob-append-sink.kamelet.yaml} (94%) copy connectors/{camel-google-sheets-source-kafka-connector => camel-coffee-source-kafka-connector}/pom.xml (94%) create mode 100644 connectors/camel-coffee-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-coffee-source-kafka-connector/src/generated/resources/camel-coffee-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-coffee-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-splunk-source-kafka-connector/src/main/docs/examples/CamelSplunksourceSourceConnector.properties => camel-coffee-source-kafka-connector/src/main/docs/examples/CamelCoffeesourceSourceConnector.properties} (73%) copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-coffee-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/coffeesource/CamelCoffeesourceSourceConnector.java (53%) create mode 100644 connectors/camel-coffee-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/coffeesource/CamelCoffeesourceSourceConnectorConfig.java copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-coffee-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/coffeesource/CamelCoffeesourceSourceTask.java (51%) copy LICENSE.txt => connectors/camel-coffee-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-coffee-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-beer-source-kafka-connector/src/main/resources/kamelets/beer-source.kamelet.yaml => camel-coffee-source-kafka-connector/src/main/resources/kamelets/coffee-source.kamelet.yaml} (96%) copy connectors/{camel-aws-ddb-sink-kafka-connector => camel-google-sheets-sink-kafka-connector}/pom.xml (94%) create mode 100644 connectors/camel-google-sheets-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-google-sheets-sink-kafka-connector/src/generated/resources/camel-google-sheets-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-google-sheets-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-splunk-source-kafka-connector/src/main/docs/examples/CamelSplunksourceSourceConnector.properties => camel-google-sheets-sink-kafka-connector/src/main/docs/examples/CamelGooglesheetssinkSinkConnector.properties} (58%) copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-google-sheets-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlesheetssink/CamelGooglesheetssinkSinkConnector.java (53%) create mode 100644 connectors/camel-google-sheets-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlesheetssink/CamelGooglesheetssinkSinkConnectorConfig.java copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-google-sheets-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlesheetssink/CamelGooglesheetssinkSinkTask.java (51%) copy LICENSE.txt => connectors/camel-google-sheets-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-google-sheets-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-google-sheets-sink-kafka-connector/src/main/resources/kamelets/google-sheets-sink.kamelet.yaml copy connectors/{camel-kafka-not-secured-sink-kafka-connector => camel-kafka-apicurio-registry-not-secured-sink-kafka-connector}/pom.xml (92%) create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/generated/resources/camel-kafka-apicurio-registry-not-secured-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-kafka-apicurio-registry-not-secured-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-splunk-source-kafka-connector/src/main/docs/examples/CamelSplunksourceSourceConnector.properties => camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/main/docs/examples/CamelKafkaapicurioregistrynotsecuredsinkSinkConnector.properties} (68%) copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsink/CamelKafkaapicurioregistrynotsecuredsinkSinkConnector.java (50%) create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsink/CamelKafkaapicurioregistrynotsecuredsinkSinkConnectorConfig.java create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsink/CamelKafkaapicurioregistrynotsecuredsinkSinkTask.java copy LICENSE.txt => connectors/camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-kafka-not-secured-sink-kafka-connector/src/main/resources/kamelets/kafka-not-secured-sink.kamelet.yaml => camel-kafka-apicurio-registry-not-secured-sink-kafka-connector/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-sink.kamelet.yaml} (79%) copy connectors/{camel-kafka-not-secured-source-kafka-connector => camel-kafka-apicurio-registry-not-secured-source-kafka-connector}/pom.xml (91%) create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/generated/resources/camel-kafka-apicurio-registry-not-secured-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-kafka-apicurio-registry-not-secured-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-splunk-source-kafka-connector/src/main/docs/examples/CamelSplunksourceSourceConnector.properties => camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/docs/examples/CamelKafkaapicurioregistrynotsecuredsourceSourceConnector.properties} (70%) create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceConnector.java create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceConnectorConfig.java create mode 100644 connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaapicurioregistrynotsecuredsource/CamelKafkaapicurioregistrynotsecuredsourceSourceTask.java copy LICENSE.txt => connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-kafka-not-secured-source-kafka-connector/src/main/resources/kamelets/kafka-not-secured-source.kamelet.yaml => camel-kafka-apicurio-registry-not-secured-source-kafka-connector/src/main/resources/kamelets/kafka-apicurio-registry-not-secured-source.kamelet.yaml} (82%) copy connectors/{camel-azure-storage-blob-changefeed-source-kafka-connector => camel-kafka-azure-schema-registry-sink-kafka-connector}/pom.xml (85%) create mode 100644 connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/src/generated/resources/camel-kafka-azure-schema-registry-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-kafka-azure-schema-registry-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-splunk-source-kafka-connector/src/main/docs/examples/CamelSplunksourceSourceConnector.properties => camel-kafka-azure-schema-registry-sink-kafka-connector/src/main/docs/examples/CamelKafkaazureschemaregistrysinkSinkConnector.properties} (67%) copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaazureschemaregistrysink/CamelKafkaazureschemaregistrysinkSinkConnector.java (51%) create mode 100644 connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaazureschemaregistrysink/CamelKafkaazureschemaregistrysinkSinkConnectorConfig.java create mode 100644 connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaazureschemaregistrysink/CamelKafkaazureschemaregistrysinkSinkTask.java copy LICENSE.txt => connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-kafka-azure-schema-registry-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-kafka-sink-kafka-connector/src/main/resources/kamelets/kafka-sink.kamelet.yaml => camel-kafka-azure-schema-registry-sink-kafka-connector/src/main/resources/kamelets/kafka-azure-schema-registry-sink.kamelet.yaml} (76%) copy connectors/{camel-azure-storage-blob-changefeed-source-kafka-connector => camel-kafka-azure-schema-registry-source-kafka-connector}/pom.xml (85%) create mode 100644 connectors/camel-kafka-azure-schema-registry-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-kafka-azure-schema-registry-source-kafka-connector/src/generated/resources/camel-kafka-azure-schema-registry-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-kafka-azure-schema-registry-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-splunk-source-kafka-connector/src/main/docs/examples/CamelSplunksourceSourceConnector.properties => camel-kafka-azure-schema-registry-source-kafka-connector/src/main/docs/examples/CamelKafkaazureschemaregistrysourceSourceConnector.properties} (68%) copy tests/itests-aws-v2/src/test/java/org/apache/camel/test/infra/aws2/services/AWSKinesisLocalContainerServiceWithTimeout.java => connectors/camel-kafka-azure-schema-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaazureschemaregistrysource/CamelKafkaazureschemaregistrysourceSourceConnector.java (50%) create mode 100644 connectors/camel-kafka-azure-schema-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaazureschemaregistrysource/CamelKafkaazureschemaregistrysourceSourceConnectorConfig.java create mode 100644 connectors/camel-kafka-azure-schema-registry-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kafkaazureschemaregistrysource/CamelKafkaazureschemaregistrysourceSourceTask.java copy LICENSE.txt => connectors/camel-kafka-azure-schema-registry-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-kafka-azure-schema-registry-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-kafka-source-kafka-connector/src/main/resources/kamelets/kafka-source.kamelet.yaml => camel-kafka-azure-schema-registry-source-kafka-connector/src/main/resources/kamelets/kafka-azure-schema-registry-source.kamelet.yaml} (79%) create mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/ByteArrayProducerPropertyFactory.java