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 b20f83a0d Updated CHANGELOG.md new 8120aa549 Updated kamelet catalog new d49c9ec30 chore: regen. The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../camel-azure-servicebus-sink-sink.json | 7 + .../camel-azure-servicebus-source-source.json | 7 + .../camel-azure-storage-datalake-sink-sink.json | 2 +- ...camel-azure-storage-datalake-source-source.json | 2 +- .../camel-github-commit-source-source.json | 6 +- .../camel-github-event-source-source.json | 6 +- ...l-github-pullrequest-comment-source-source.json | 6 +- .../camel-github-pullrequest-source-source.json | 6 +- .../connectors/camel-github-tag-source-source.json | 6 +- .../camel-jira-add-comment-sink-sink.json | 18 +- .../connectors/camel-jira-add-issue-sink-sink.json | 18 +- .../connectors/camel-jira-source-source.json | 18 +- .../camel-jira-transition-issue-sink-sink.json | 18 +- .../camel-jira-update-issue-sink-sink.json | 18 +- .../connectors/camel-minio-sink-sink.json | 6 + .../camel-opensearch-index-sink-sink.json | 56 +++++ .../camel-opensearch-search-source-source.json | 69 ++++++ ...amel-salesforce-composite-upsert-sink-sink.json | 56 +++++ .../connectors/camel-sqlserver-sink-sink.json | 2 +- .../connectors/camel-sqlserver-source-source.json | 2 +- .../resources/descriptors/connectors.properties | 5 + .../kamelets/aws-cloudtrail-source.kamelet.yaml | 4 +- .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 4 +- .../camel-aws-ddb-sink-kafka-connector/pom.xml | 10 +- .../resources/kamelets/aws-ddb-sink.kamelet.yaml | 19 +- .../kamelets/aws-ddb-streams-source.kamelet.yaml | 4 +- .../resources/kamelets/aws-ec2-sink.kamelet.yaml | 4 +- .../kamelets/aws-eventbridge-sink.kamelet.yaml | 4 +- .../aws-kinesis-firehose-sink.kamelet.yaml | 4 +- .../kamelets/aws-kinesis-sink.kamelet.yaml | 4 +- .../pom.xml | 10 +- .../kamelets/aws-kinesis-source.kamelet.yaml | 6 +- .../kamelets/aws-lambda-sink.kamelet.yaml | 4 +- .../pom.xml | 16 +- .../kamelets/aws-redshift-sink.kamelet.yaml | 8 +- .../pom.xml | 16 +- .../kamelets/aws-redshift-source.kamelet.yaml | 8 +- .../kamelets/aws-s3-cdc-source.kamelet.yaml | 4 +- .../resources/kamelets/aws-s3-sink.kamelet.yaml | 4 +- .../camel-aws-s3-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/aws-s3-source.kamelet.yaml | 6 +- .../aws-s3-streaming-upload-sink.kamelet.yaml | 4 +- .../kamelets/aws-secrets-manager-sink.kamelet.yaml | 4 +- .../resources/kamelets/aws-ses-sink.kamelet.yaml | 4 +- .../kamelets/aws-sns-fifo-sink.kamelet.yaml | 4 +- .../resources/kamelets/aws-sns-sink.kamelet.yaml | 4 +- .../kamelets/aws-sqs-batch-sink.kamelet.yaml | 4 +- .../kamelets/aws-sqs-fifo-sink.kamelet.yaml | 4 +- .../resources/kamelets/aws-sqs-sink.kamelet.yaml | 4 +- .../camel-aws-sqs-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/aws-sqs-source.kamelet.yaml | 6 +- .../kamelets/azure-cosmosdb-sink.kamelet.yaml | 6 +- .../kamelets/azure-cosmosdb-source.kamelet.yaml | 4 +- .../kamelets/azure-eventhubs-sink.kamelet.yaml | 4 +- .../kamelets/azure-eventhubs-source.kamelet.yaml | 4 +- .../kamelets/azure-functions-sink.kamelet.yaml | 4 +- .../camel-azure-servicebus-sink-sink.json | 7 + ...amelAzureservicebussinkSinkConnectorConfig.java | 4 + .../kamelets/azure-servicebus-sink.kamelet.yaml | 11 +- .../camel-azure-servicebus-source-source.json | 7 + ...AzureservicebussourceSourceConnectorConfig.java | 4 + .../kamelets/azure-servicebus-source.kamelet.yaml | 11 +- .../azure-storage-blob-cdc-source.kamelet.yaml | 4 +- ...ure-storage-blob-changefeed-source.kamelet.yaml | 4 +- .../kamelets/azure-storage-blob-sink.kamelet.yaml | 4 +- .../pom.xml | 10 +- .../azure-storage-blob-source.kamelet.yaml | 6 +- .../pom.xml | 18 +- .../descriptors/connector-sink.properties | 1 + .../camel-azure-storage-datalake-sink-sink.json | 2 +- .../src/main/assembly/package.xml | 0 ...urestoragedatalakesinkSinkConnector.properties} | 16 +- ...amelAzurestoragedatalakesinkSinkConnector.java} | 8 +- ...zurestoragedatalakesinkSinkConnectorConfig.java | 64 +++++ .../CamelAzurestoragedatalakesinkSinkTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../azure-storage-datalake-sink.kamelet.yaml | 113 +++++++++ .../pom.xml | 18 +- .../descriptors/connector-source.properties | 1 + ...camel-azure-storage-datalake-source-source.json | 2 +- .../src/main/assembly/package.xml | 0 ...toragedatalakesourceSourceConnector.properties} | 16 +- ...AzurestoragedatalakesourceSourceConnector.java} | 8 +- ...storagedatalakesourceSourceConnectorConfig.java | 68 ++++++ ...CamelAzurestoragedatalakesourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../azure-storage-datalake-source.kamelet.yaml | 100 ++++++++ .../kamelets/azure-storage-queue-sink.kamelet.yaml | 4 +- .../pom.xml | 10 +- .../azure-storage-queue-source.kamelet.yaml | 6 +- .../resources/kamelets/beer-source.kamelet.yaml | 4 +- .../resources/kamelets/bitcoin-source.kamelet.yaml | 4 +- .../resources/kamelets/cassandra-sink.kamelet.yaml | 4 +- .../kamelets/cassandra-source.kamelet.yaml | 4 +- .../main/resources/kamelets/ceph-sink.kamelet.yaml | 4 +- .../resources/kamelets/ceph-source.kamelet.yaml | 4 +- .../kamelets/chuck-norris-source.kamelet.yaml | 4 +- .../resources/kamelets/couchbase-sink.kamelet.yaml | 4 +- .../resources/kamelets/cron-source.kamelet.yaml | 4 +- .../resources/kamelets/dropbox-sink.kamelet.yaml | 4 +- .../resources/kamelets/dropbox-source.kamelet.yaml | 4 +- .../kamelets/earthquake-source.kamelet.yaml | 4 +- .../kamelets/elasticsearch-index-sink.kamelet.yaml | 4 +- .../elasticsearch-search-source.kamelet.yaml | 4 +- .../main/resources/kamelets/exec-sink.kamelet.yaml | 4 +- .../main/resources/kamelets/fhir-sink.kamelet.yaml | 4 +- .../resources/kamelets/fhir-source.kamelet.yaml | 4 +- .../kamelets/file-watch-source.kamelet.yaml | 4 +- .../main/resources/kamelets/ftp-sink.kamelet.yaml | 4 +- .../resources/kamelets/ftp-source.kamelet.yaml | 4 +- .../main/resources/kamelets/ftps-sink.kamelet.yaml | 4 +- .../resources/kamelets/ftps-source.kamelet.yaml | 4 +- .../camel-github-commit-source-source.json | 6 +- ...melGithubcommitsourceSourceConnector.properties | 4 +- ...melGithubcommitsourceSourceConnectorConfig.java | 4 +- .../kamelets/github-commit-source.kamelet.yaml | 12 +- .../camel-github-event-source-source.json | 6 +- ...amelGithubeventsourceSourceConnector.properties | 4 +- ...amelGithubeventsourceSourceConnectorConfig.java | 4 +- .../kamelets/github-event-source.kamelet.yaml | 12 +- ...l-github-pullrequest-comment-source-source.json | 6 +- ...lrequestcommentsourceSourceConnector.properties | 4 +- ...lrequestcommentsourceSourceConnectorConfig.java | 4 +- .../github-pullrequest-comment-source.kamelet.yaml | 12 +- .../camel-github-pullrequest-source-source.json | 6 +- ...thubpullrequestsourceSourceConnector.properties | 4 +- ...thubpullrequestsourceSourceConnectorConfig.java | 4 +- .../github-pullrequest-source.kamelet.yaml | 12 +- .../resources/camel-github-tag-source-source.json | 6 +- .../CamelGithubtagsourceSourceConnector.properties | 4 +- .../CamelGithubtagsourceSourceConnectorConfig.java | 4 +- .../kamelets/github-tag-source.kamelet.yaml | 12 +- .../kamelets/google-bigquery-sink.kamelet.yaml | 4 +- .../kamelets/google-calendar-source.kamelet.yaml | 4 +- .../kamelets/google-functions-sink.kamelet.yaml | 4 +- .../kamelets/google-mail-source.kamelet.yaml | 4 +- .../kamelets/google-pubsub-sink.kamelet.yaml | 4 +- .../kamelets/google-pubsub-source.kamelet.yaml | 4 +- .../kamelets/google-sheets-source.kamelet.yaml | 4 +- .../google-storage-cdc-source.kamelet.yaml | 4 +- .../kamelets/google-storage-sink.kamelet.yaml | 4 +- .../kamelets/google-storage-source.kamelet.yaml | 4 +- .../resources/kamelets/graphql-sink.kamelet.yaml | 4 +- .../kamelets/http-secured-sink.kamelet.yaml | 4 +- .../kamelets/http-secured-source.kamelet.yaml | 4 +- .../main/resources/kamelets/http-sink.kamelet.yaml | 4 +- .../resources/kamelets/http-source.kamelet.yaml | 4 +- .../kamelets/infinispan-sink.kamelet.yaml | 4 +- .../kamelets/infinispan-source.kamelet.yaml | 4 +- .../camel-jira-add-comment-sink-sink.json | 18 +- ...CamelJiraaddcommentsinkSinkConnector.properties | 4 - ...CamelJiraaddcommentsinkSinkConnectorConfig.java | 10 +- .../kamelets/jira-add-comment-sink.kamelet.yaml | 21 +- .../resources/camel-jira-add-issue-sink-sink.json | 18 +- .../CamelJiraaddissuesinkSinkConnector.properties | 4 - .../CamelJiraaddissuesinkSinkConnectorConfig.java | 10 +- .../kamelets/jira-add-issue-sink.kamelet.yaml | 21 +- .../kamelets/jira-oauth-source.kamelet.yaml | 4 +- .../resources/camel-jira-source-source.json | 18 +- .../CamelJirasourceSourceConnector.properties | 4 - .../CamelJirasourceSourceConnectorConfig.java | 10 +- .../resources/kamelets/jira-source.kamelet.yaml | 22 +- .../camel-jira-transition-issue-sink-sink.json | 18 +- ...JiratransitionissuesinkSinkConnector.properties | 4 - ...JiratransitionissuesinkSinkConnectorConfig.java | 10 +- .../jira-transition-issue-sink.kamelet.yaml | 21 +- .../camel-jira-update-issue-sink-sink.json | 18 +- ...amelJiraupdateissuesinkSinkConnector.properties | 4 - ...amelJiraupdateissuesinkSinkConnectorConfig.java | 10 +- .../kamelets/jira-update-issue-sink.kamelet.yaml | 21 +- .../kamelets/jms-amqp-10-sink.kamelet.yaml | 4 +- .../kamelets/jms-amqp-10-source.kamelet.yaml | 4 +- .../pom.xml | 2 +- .../kamelets/jms-apache-artemis-sink.kamelet.yaml | 6 +- .../pom.xml | 2 +- .../jms-apache-artemis-source.kamelet.yaml | 6 +- .../kamelets/jms-ibm-mq-sink.kamelet.yaml | 4 +- .../kamelets/jms-ibm-mq-source.kamelet.yaml | 4 +- .../pom.xml | 10 +- .../kamelets/kafka-not-secured-sink.kamelet.yaml | 6 +- .../pom.xml | 10 +- .../kamelets/kafka-not-secured-source.kamelet.yaml | 6 +- .../kamelets/kafka-scram-sink.kamelet.yaml | 4 +- .../pom.xml | 10 +- .../kamelets/kafka-scram-source.kamelet.yaml | 6 +- .../resources/kamelets/kafka-sink.kamelet.yaml | 4 +- .../camel-kafka-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/kafka-source.kamelet.yaml | 6 +- .../resources/kamelets/kafka-ssl-sink.kamelet.yaml | 4 +- .../camel-kafka-ssl-source-kafka-connector/pom.xml | 10 +- .../kamelets/kafka-ssl-source.kamelet.yaml | 6 +- .../kubernetes-namespaces-source.kamelet.yaml | 4 +- .../kamelets/kubernetes-nodes-source.kamelet.yaml | 4 +- .../kamelets/kubernetes-pods-source.kamelet.yaml | 4 +- .../main/resources/kamelets/log-sink.kamelet.yaml | 4 +- .../kamelets/mail-imap-source.kamelet.yaml | 4 +- .../main/resources/kamelets/mail-sink.kamelet.yaml | 4 +- .../camel-mariadb-sink-kafka-connector/pom.xml | 10 +- .../resources/kamelets/mariadb-sink.kamelet.yaml | 6 +- .../camel-mariadb-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/mariadb-source.kamelet.yaml | 6 +- .../generated/resources/camel-minio-sink-sink.json | 6 + .../CamelMiniosinkSinkConnectorConfig.java | 4 + .../resources/kamelets/minio-sink.kamelet.yaml | 46 ++-- .../resources/kamelets/minio-source.kamelet.yaml | 4 +- .../pom.xml | 5 + .../mongodb-changes-stream-source.kamelet.yaml | 5 +- .../camel-mongodb-sink-kafka-connector/pom.xml | 5 + .../resources/kamelets/mongodb-sink.kamelet.yaml | 5 +- .../camel-mongodb-source-kafka-connector/pom.xml | 5 + .../resources/kamelets/mongodb-source.kamelet.yaml | 5 +- .../main/resources/kamelets/mqtt-sink.kamelet.yaml | 4 +- .../resources/kamelets/mqtt-source.kamelet.yaml | 4 +- .../resources/kamelets/mqtt5-sink.kamelet.yaml | 4 +- .../resources/kamelets/mqtt5-source.kamelet.yaml | 4 +- .../camel-mysql-sink-kafka-connector/pom.xml | 10 +- .../resources/kamelets/mysql-sink.kamelet.yaml | 6 +- .../camel-mysql-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/mysql-source.kamelet.yaml | 6 +- .../main/resources/kamelets/nats-sink.kamelet.yaml | 4 +- .../resources/kamelets/nats-source.kamelet.yaml | 4 +- .../pom.xml | 8 +- .../descriptors/connector-sink.properties | 1 + .../camel-opensearch-index-sink-sink.json | 56 +++++ .../src/main/assembly/package.xml | 0 ...melOpensearchindexsinkSinkConnector.properties} | 10 +- .../CamelOpensearchindexsinkSinkConnector.java} | 8 +- ...amelOpensearchindexsinkSinkConnectorConfig.java | 72 ++++++ .../CamelOpensearchindexsinkSinkTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kamelets/opensearch-index-sink.kamelet.yaml | 147 ++++++++++++ .../pom.xml | 8 +- .../descriptors/connector-source.properties | 1 + .../camel-opensearch-search-source-source.json | 69 ++++++ .../src/main/assembly/package.xml | 0 ...ensearchsearchsourceSourceConnector.properties} | 14 +- ...amelOpensearchsearchsourceSourceConnector.java} | 8 +- ...pensearchsearchsourceSourceConnectorConfig.java | 80 +++++++ .../CamelOpensearchsearchsourceSourceTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kamelets/opensearch-search-source.kamelet.yaml | 126 ++++++++++ .../pom.xml | 10 +- .../kamelets/oracle-database-sink.kamelet.yaml | 6 +- .../pom.xml | 10 +- .../kamelets/oracle-database-source.kamelet.yaml | 6 +- .../camel-postgresql-sink-kafka-connector/pom.xml | 10 +- .../kamelets/postgresql-sink.kamelet.yaml | 6 +- .../pom.xml | 10 +- .../kamelets/postgresql-source.kamelet.yaml | 6 +- .../resources/kamelets/pulsar-sink.kamelet.yaml | 4 +- .../resources/kamelets/pulsar-source.kamelet.yaml | 4 +- .../resources/kamelets/redis-sink.kamelet.yaml | 4 +- .../resources/kamelets/redis-source.kamelet.yaml | 4 +- .../kamelets/rest-openapi-sink.kamelet.yaml | 4 +- .../pom.xml | 6 +- .../descriptors/connector-sink.properties | 1 + ...amel-salesforce-composite-upsert-sink-sink.json | 56 +++++ .../src/main/assembly/package.xml | 0 ...rcecompositeupsertsinkSinkConnector.properties} | 16 +- ...alesforcecompositeupsertsinkSinkConnector.java} | 8 +- ...orcecompositeupsertsinkSinkConnectorConfig.java | 72 ++++++ ...amelSalesforcecompositeupsertsinkSinkTask.java} | 8 +- .../src/main/resources/META-INF/LICENSE.txt | 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../salesforce-composite-upsert-sink.kamelet.yaml} | 40 +++- .../kamelets/salesforce-create-sink.kamelet.yaml | 4 +- .../kamelets/salesforce-delete-sink.kamelet.yaml | 4 +- .../kamelets/salesforce-source.kamelet.yaml | 4 +- .../kamelets/salesforce-update-sink.kamelet.yaml | 4 +- .../main/resources/kamelets/scp-sink.kamelet.yaml | 4 +- .../main/resources/kamelets/sftp-sink.kamelet.yaml | 4 +- .../resources/kamelets/sftp-source.kamelet.yaml | 4 +- .../resources/kamelets/slack-sink.kamelet.yaml | 4 +- .../resources/kamelets/slack-source.kamelet.yaml | 4 +- .../kamelets/splunk-hec-sink.kamelet.yaml | 4 +- .../resources/kamelets/splunk-sink.kamelet.yaml | 4 +- .../resources/kamelets/splunk-source.kamelet.yaml | 4 +- .../camel-sqlserver-sink-kafka-connector/pom.xml | 10 +- .../resources/camel-sqlserver-sink-sink.json | 2 +- .../CamelSqlserversinkSinkConnectorConfig.java | 2 +- .../resources/kamelets/sqlserver-sink.kamelet.yaml | 8 +- .../camel-sqlserver-source-kafka-connector/pom.xml | 10 +- .../resources/camel-sqlserver-source-source.json | 2 +- .../CamelSqlserversourceSourceConnectorConfig.java | 2 +- .../kamelets/sqlserver-source.kamelet.yaml | 8 +- .../main/resources/kamelets/ssh-sink.kamelet.yaml | 4 +- .../resources/kamelets/ssh-source.kamelet.yaml | 4 +- .../resources/kamelets/telegram-sink.kamelet.yaml | 4 +- .../kamelets/telegram-source.kamelet.yaml | 4 +- .../resources/kamelets/timer-source.kamelet.yaml | 4 +- .../twitter-directmessage-source.kamelet.yaml | 4 +- .../kamelets/twitter-search-source.kamelet.yaml | 4 +- .../kamelets/twitter-timeline-source.kamelet.yaml | 4 +- .../resources/kamelets/webhook-source.kamelet.yaml | 4 +- .../resources/kamelets/wttrin-source.kamelet.yaml | 4 +- connectors/pom.xml | 8 +- .../SchemaAndStructToJsonTransformTest.java | 12 +- .../SinkPojoToSchemaAndStructTransformTest.java | 12 +- .../kafkaconnector/transforms/SlackMessage.java | 259 --------------------- docs/modules/ROOT/nav.adoc | 10 + docs/modules/ROOT/pages/reference/index.adoc | 7 +- parent/pom.xml | 2 +- tests/itests-mongodb/pom.xml | 1 - .../CamelKafkaConnectorKameletUpdateMojo.java | 2 +- .../maven_project/pom.xml | 3 - 309 files changed, 2264 insertions(+), 1077 deletions(-) create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-opensearch-index-sink-sink.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-opensearch-search-source-source.json create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-salesforce-composite-upsert-sink-sink.json copy connectors/{camel-aws-ddb-sink-kafka-connector => camel-azure-storage-datalake-sink-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-azure-storage-datalake-sink-kafka-connector/src/generated/descriptors/connector-sink.properties copy {camel-kafka-connector-catalog/src/generated/resources/connectors => connectors/camel-azure-storage-datalake-sink-kafka-connector/src/generated/resources}/camel-azure-storage-datalake-sink-sink.json (98%) copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-azure-storage-datalake-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-aws-ec2-sink-kafka-connector/src/main/docs/examples/CamelAwsec2sinkSinkConnector.properties => camel-azure-storage-datalake-sink-kafka-connector/src/main/docs/examples/CamelAzurestoragedatalakesinkSinkConnector.properties} (65%) copy connectors/{camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3streaminguploadsink/CamelAwss3streaminguploadsinkSinkConnector.java => camel-azure-storage-datalake-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalakesink/CamelAzurestoragedatalakesinkSinkConnector.java} (84%) create mode 100644 connectors/camel-azure-storage-datalake-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalakesink/CamelAzurestoragedatalakesinkSinkConnectorConfig.java copy connectors/{camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3streaminguploadsink/CamelAwss3streaminguploadsinkSinkTask.java => camel-azure-storage-datalake-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalakesink/CamelAzurestoragedatalakesinkSinkTask.java} (84%) copy LICENSE.txt => connectors/camel-azure-storage-datalake-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-azure-storage-datalake-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-azure-storage-datalake-sink-kafka-connector/src/main/resources/kamelets/azure-storage-datalake-sink.kamelet.yaml copy connectors/{camel-aws-ddb-sink-kafka-connector => camel-azure-storage-datalake-source-kafka-connector}/pom.xml (93%) create mode 100644 connectors/camel-azure-storage-datalake-source-kafka-connector/src/generated/descriptors/connector-source.properties copy {camel-kafka-connector-catalog/src/generated/resources/connectors => connectors/camel-azure-storage-datalake-source-kafka-connector/src/generated/resources}/camel-azure-storage-datalake-source-source.json (98%) copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-azure-storage-datalake-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-aws-cloudtrail-source-kafka-connector/src/main/docs/examples/CamelAwscloudtrailsourceSourceConnector.properties => camel-azure-storage-datalake-source-kafka-connector/src/main/docs/examples/CamelAzurestoragedatalakesourceSourceConnector.properties} (65%) copy connectors/{camel-kubernetes-namespaces-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kubernetesnamespacessource/CamelKubernetesnamespacessourceSourceConnector.java => camel-azure-storage-datalake-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalakesource/CamelAzurestoragedatalakesourceSourceConnector.java} (84%) create mode 100644 connectors/camel-azure-storage-datalake-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalakesource/CamelAzurestoragedatalakesourceSourceConnectorConfig.java copy connectors/{camel-twitter-directmessage-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/twitterdirectmessagesource/CamelTwitterdirectmessagesourceSourceTask.java => camel-azure-storage-datalake-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalakesource/CamelAzurestoragedatalakesourceSourceTask.java} (85%) copy LICENSE.txt => connectors/camel-azure-storage-datalake-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-azure-storage-datalake-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-azure-storage-datalake-source-kafka-connector/src/main/resources/kamelets/azure-storage-datalake-source.kamelet.yaml copy connectors/{camel-elasticsearch-index-sink-kafka-connector => camel-opensearch-index-sink-kafka-connector}/pom.xml (95%) create mode 100644 connectors/camel-opensearch-index-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-opensearch-index-sink-kafka-connector/src/generated/resources/camel-opensearch-index-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-opensearch-index-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-elasticsearch-index-sink-kafka-connector/src/main/docs/examples/CamelElasticsearchindexsinkSinkConnector.properties => camel-opensearch-index-sink-kafka-connector/src/main/docs/examples/CamelOpensearchindexsinkSinkConnector.properties} (81%) copy connectors/{camel-azure-servicebus-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureservicebussink/CamelAzureservicebussinkSinkConnector.java => camel-opensearch-index-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/opensearchindexsink/CamelOpensearchindexsinkSinkConnector.java} (83%) create mode 100644 connectors/camel-opensearch-index-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/opensearchindexsink/CamelOpensearchindexsinkSinkConnectorConfig.java copy connectors/{camel-azure-servicebus-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azureservicebussink/CamelAzureservicebussinkSinkTask.java => camel-opensearch-index-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/opensearchindexsink/CamelOpensearchindexsinkSinkTask.java} (84%) copy LICENSE.txt => connectors/camel-opensearch-index-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-opensearch-index-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-opensearch-index-sink-kafka-connector/src/main/resources/kamelets/opensearch-index-sink.kamelet.yaml copy connectors/{camel-elasticsearch-search-source-kafka-connector => camel-opensearch-search-source-kafka-connector}/pom.xml (94%) create mode 100644 connectors/camel-opensearch-search-source-kafka-connector/src/generated/descriptors/connector-source.properties create mode 100644 connectors/camel-opensearch-search-source-kafka-connector/src/generated/resources/camel-opensearch-search-source-source.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-opensearch-search-source-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-elasticsearch-search-source-kafka-connector/src/main/docs/examples/CamelElasticsearchsearchsourceSourceConnector.properties => camel-opensearch-search-source-kafka-connector/src/main/docs/examples/CamelOpensearchsearchsourceSourceConnector.properties} (76%) copy connectors/{camel-azure-storage-blob-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobsource/CamelAzurestorageblobsourceSourceConnector.java => camel-opensearch-search-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/opensearchsearchsource/CamelOpensearchsearchsourceSourceConnector.java} (84%) create mode 100644 connectors/camel-opensearch-search-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/opensearchsearchsource/CamelOpensearchsearchsourceSourceConnectorConfig.java copy connectors/{camel-azure-storage-blob-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestorageblobsource/CamelAzurestorageblobsourceSourceTask.java => camel-opensearch-search-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/opensearchsearchsource/CamelOpensearchsearchsourceSourceTask.java} (84%) copy LICENSE.txt => connectors/camel-opensearch-search-source-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-opensearch-search-source-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) create mode 100644 connectors/camel-opensearch-search-source-kafka-connector/src/main/resources/kamelets/opensearch-search-source.kamelet.yaml copy connectors/{camel-salesforce-update-sink-kafka-connector => camel-salesforce-composite-upsert-sink-kafka-connector}/pom.xml (95%) create mode 100644 connectors/camel-salesforce-composite-upsert-sink-kafka-connector/src/generated/descriptors/connector-sink.properties create mode 100644 connectors/camel-salesforce-composite-upsert-sink-kafka-connector/src/generated/resources/camel-salesforce-composite-upsert-sink-sink.json copy connectors/{camel-aws-cloudtrail-source-kafka-connector => camel-salesforce-composite-upsert-sink-kafka-connector}/src/main/assembly/package.xml (100%) copy connectors/{camel-salesforce-create-sink-kafka-connector/src/main/docs/examples/CamelSalesforcecreatesinkSinkConnector.properties => camel-salesforce-composite-upsert-sink-kafka-connector/src/main/docs/examples/CamelSalesforcecompositeupsertsinkSinkConnector.properties} (67%) copy connectors/{camel-jms-apache-artemis-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/jmsapacheartemissink/CamelJmsapacheartemissinkSinkConnector.java => camel-salesforce-composite-upsert-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforcecompositeupsertsink/CamelSalesforcecompositeupsertsinkSinkConnector.java} (82%) create mode 100644 connectors/camel-salesforce-composite-upsert-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforcecompositeupsertsink/CamelSalesforcecompositeupsertsinkSinkConnectorConfig.java copy connectors/{camel-aws-ec2-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awsec2sink/CamelAwsec2sinkSinkTask.java => camel-salesforce-composite-upsert-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforcecompositeupsertsink/CamelSalesforcecompositeupsertsinkSinkTask.java} (82%) copy LICENSE.txt => connectors/camel-salesforce-composite-upsert-sink-kafka-connector/src/main/resources/META-INF/LICENSE.txt (100%) copy NOTICE.txt => connectors/camel-salesforce-composite-upsert-sink-kafka-connector/src/main/resources/META-INF/NOTICE.txt (100%) copy connectors/{camel-salesforce-create-sink-kafka-connector/src/main/resources/kamelets/salesforce-create-sink.kamelet.yaml => camel-salesforce-composite-upsert-sink-kafka-connector/src/main/resources/kamelets/salesforce-composite-upsert-sink.kamelet.yaml} (90%) delete mode 100644 core/src/test/java/org/apache/camel/kafkaconnector/transforms/SlackMessage.java