[camel-kafka-connector] tag camel-kafka-connector-3.20.6 deleted (was 82226b34a)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-3.20.6 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git *** WARNING: tag camel-kafka-connector-3.20.6 was deleted! *** was 82226b34a [after release perform chore]: regen catalog descriptors with new version This change permanently discards the following revisions: discard 82226b34a [after release perform chore]: regen catalog descriptors with new version
[camel-kafka-connector] branch camel-kafka-connector-3.20.x updated (b0d8c021d -> c367ca3b6)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-3.20.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git discard b0d8c021d [maven-release-plugin] prepare for next development iteration This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/camel-kafka-connector-3.20.x (c367ca3b6) \ O -- O -- O (b0d8c021d) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 6 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 6 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 6 +- archetypes/pom.xml | 6 +- buildingtools/pom.xml | 6 +- camel-kafka-connector-catalog/pom.xml | 6 +- connectors/camel-aws-cloudtrail-source-kafka-connector/pom.xml | 5 - connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml| 5 - connectors/camel-aws-ddb-experimental-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 5 - connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 5 - connectors/camel-aws-lambda-sink-kafka-connector/pom.xml| 5 - connectors/camel-aws-redshift-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-redshift-source-kafka-connector/pom.xml| 5 - connectors/camel-aws-s3-cdc-source-kafka-connector/pom.xml | 5 - connectors/camel-aws-s3-experimental-source-kafka-connector/pom.xml | 5 - connectors/camel-aws-s3-sink-kafka-connector/pom.xml| 5 - connectors/camel-aws-s3-source-kafka-connector/pom.xml | 5 - .../camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 5 - connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 5 - connectors/camel-aws2-iam-kafka-connector/pom.xml | 5 - connectors/camel-aws2-kms-kafka-connector/pom.xml | 5 - connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml | 5 - connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 5 - connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 5 - connectors/camel-azure-functions-sink-kafka-connector/pom.xml | 5 - connectors/camel-azure-servicebus-sink-kafka-connector/pom.xml | 5 - connectors/camel-azure-servicebus-source-kafka-connector/pom.xml| 5 - .../camel-azure-storage-blob-cdc-source-kafka-connector/pom.xml | 5 - .../pom.xml | 5 - connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml| 5 - connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml | 5 - connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 5 - connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 5 - connectors/camel-beer-source-kafka-connector/pom.xml| 5 - connectors/camel-bitcoin-source-kafka-connector/pom.xml | 5 - connectors/camel-cassandra-sink-kafka-connector/pom.xml | 5 - connectors/camel-cassandra-source-kafka-connector/pom.xml | 5 - connectors/camel-ceph-sink-kafka-connector/pom.xml | 5 - connectors/camel-ceph-source-kafka-connector/pom.xml| 5 - connectors/camel-chuck-norris-source-kafka-connector/pom.xml| 5 - connectors/camel-couchbase-sink-kaf
[camel-kafka-connector] tag camel-kafka-connector-3.20.6 updated (ceb4ab9de -> 82226b34a)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-3.20.6 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git *** WARNING: tag camel-kafka-connector-3.20.6 was modified! *** from ceb4ab9de (tag) to 82226b34a (commit) from c367ca3b6 [maven-release-plugin] prepare release camel-kafka-connector-3.20.6 new 82226b34a [after release perform chore]: regen catalog descriptors with new version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../resources/connectors/camel-aws-cloudtrail-source-source.json| 2 +- .../generated/resources/connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-experimental-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-streams-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-eventbridge-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-kinesis-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-lambda-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-redshift-sink-sink.json| 2 +- .../resources/connectors/camel-aws-redshift-source-source.json | 2 +- .../generated/resources/connectors/camel-aws-s3-cdc-source-source.json | 2 +- .../resources/connectors/camel-aws-s3-experimental-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-source-source.json | 2 +- .../resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ses-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-fifo-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-sns-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-fifo-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-sqs-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sqs-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../resources/connectors/camel-azure-cosmosdb-source-source.json| 2 +- .../generated/resources/connectors/camel-azure-eventhubs-sink-sink.json | 2 +- .../resources/connectors/camel-azure-eventhubs-source-source.json | 2 +- .../generated/resources/connectors/camel-azure-functions-sink-sink.json | 2 +- .../resources/connectors/camel-azure-servicebus-sink-sink.json | 2 +- .../resources/connectors/camel-azure-servicebus-source-source.json | 2 +- .../connectors/camel-azure-storage-blob-cdc-source-source.json | 2 +- .../connectors/camel-azure-storage-blob-changefeed-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-blob-sink-sink.json| 2 +- .../resources/connectors/camel-azure-storage-blob-source-source.json| 2 +- .../resources/connectors/camel-azure-storage-queue-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-queue-source-source.json | 2 +- .../src/generated/resources/connectors/camel-beer-source-source.json| 2 +- .../src/generated/resources/connectors/camel-bitcoin-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cassandra-sink-sink.json | 2 +- .../generated/resources/connectors/camel-cassandra-source-source.json | 2 +- .../src/generated/resources/connectors/camel-ceph-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-ceph-source-source.json| 2 +- .../resources/connectors/camel-chuck-norris-source-source.json | 2 +- .../src/generated/resources/connectors/camel-couchbase-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-cron-source-source.json| 2 +- .../src/generated/resources/connectors/camel-cxf-sink.json | 2 +- .../src/generated/resources/connectors/camel-cxf-source.json| 2 +- .../src/generated/resources/connectors/camel-cxfrs-sink.json| 2 +- .../src/generated/resources/connectors/camel-cxfrs-sour
[camel-kafka-connector] annotated tag camel-kafka-connector-3.20.6 created (now ceb4ab9de)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-3.20.6 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at ceb4ab9de (tag) tagging c367ca3b6afcf860afa4b44bb3016eaa7c55c60e (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Wed Jul 26 15:50:34 2023 +0200 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-3.20.6 --- No new revisions were added by this update.
[camel-website] branch valdar-patch-1 created (now 6568a52d)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git at 6568a52d Create release-3.20.3.md No new revisions were added by this update.
svn commit: r61621 - in /release/camel/camel-kafka-connector/3.20.3: ./ camel-kafka-connector-3.20.3-src.zip camel-kafka-connector-3.20.3-src.zip.asc camel-kafka-connector-3.20.3-src.zip.sha512
Author: valdar Date: Wed May 3 10:19:09 2023 New Revision: 61621 Log: Camel Kafka Connector 3.20.3 import Added: release/camel/camel-kafka-connector/3.20.3/ release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip (with props) release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip.asc (with props) release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip.sha512 Added: release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip.sha512 == --- release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/3.20.3/camel-kafka-connector-3.20.3-src.zip.sha512 Wed May 3 10:19:09 2023 @@ -0,0 +1 @@ +d3cf51e215a9121da5cc53c4e7f3b46db067904ffbee694f60214193f50a60273aeb12e1bca022f54cae6a915606abd1a3452466ab64f6dcc00a77012408e967 \ No newline at end of file
[camel-kafka-connector] tag camel-kafka-connector-3.20.3 updated (4755fd617 -> f0e2ca924)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-3.20.3 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git *** WARNING: tag camel-kafka-connector-3.20.3 was modified! *** from 4755fd617 (tag) to f0e2ca924 (commit) from 46c7b3e26 [maven-release-plugin] prepare release camel-kafka-connector-3.20.3 new f0e2ca924 [after release perform chore]: regen catalog descriptors with new version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../resources/connectors/camel-aws-cloudtrail-source-source.json| 2 +- .../generated/resources/connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-experimental-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-streams-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-eventbridge-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-kinesis-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-lambda-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-redshift-sink-sink.json| 2 +- .../resources/connectors/camel-aws-redshift-source-source.json | 2 +- .../generated/resources/connectors/camel-aws-s3-cdc-source-source.json | 2 +- .../resources/connectors/camel-aws-s3-experimental-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-source-source.json | 2 +- .../resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ses-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-fifo-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-sns-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-fifo-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-sqs-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sqs-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../resources/connectors/camel-azure-cosmosdb-source-source.json| 2 +- .../generated/resources/connectors/camel-azure-eventhubs-sink-sink.json | 2 +- .../resources/connectors/camel-azure-eventhubs-source-source.json | 2 +- .../generated/resources/connectors/camel-azure-functions-sink-sink.json | 2 +- .../resources/connectors/camel-azure-servicebus-sink-sink.json | 2 +- .../resources/connectors/camel-azure-servicebus-source-source.json | 2 +- .../connectors/camel-azure-storage-blob-cdc-source-source.json | 2 +- .../connectors/camel-azure-storage-blob-changefeed-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-blob-sink-sink.json| 2 +- .../resources/connectors/camel-azure-storage-blob-source-source.json| 2 +- .../resources/connectors/camel-azure-storage-queue-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-queue-source-source.json | 2 +- .../src/generated/resources/connectors/camel-beer-source-source.json| 2 +- .../src/generated/resources/connectors/camel-bitcoin-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cassandra-sink-sink.json | 2 +- .../generated/resources/connectors/camel-cassandra-source-source.json | 2 +- .../src/generated/resources/connectors/camel-ceph-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-ceph-source-source.json| 2 +- .../resources/connectors/camel-chuck-norris-source-source.json | 2 +- .../src/generated/resources/connectors/camel-couchbase-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-cron-source-source.json| 2 +- .../src/generated/resources/connectors/camel-cxf-sink.json | 2 +- .../src/generated/resources/connectors/camel-cxf-source.json| 2 +- .../src/generated/resources/connectors/camel-cxfrs-sink.json| 2 +- .../src/generated/resources/connectors/camel-cxfrs-sour
[camel-kafka-connector] annotated tag camel-kafka-connector-3.20.3 created (now 4755fd617)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-3.20.3 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at 4755fd617 (tag) tagging 46c7b3e26fe61a4cf809c774ec2828171a8c7de4 (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Thu Apr 20 10:12:14 2023 +0200 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-3.20.3 --- No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-3.20.x updated (0c266c66a -> be1bc4a71)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-3.20.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git from 0c266c66a [maven-release-plugin] prepare for next development iteration new 9e0cf301e chore: fixed formatting. new be1bc4a71 Updated to camel 3.20.3 and 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-aws-cloudtrail-source-source.json| 2 +- .../connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../camel-aws-ddb-experimental-sink-sink.json | 4 ++-- .../connectors/camel-aws-ddb-sink-sink.json| 13 +++- .../camel-aws-ddb-streams-source-source.json | 2 +- .../connectors/camel-aws-ec2-sink-sink.json| 2 +- .../camel-aws-eventbridge-sink-sink.json | 2 +- .../camel-aws-kinesis-firehose-sink-sink.json | 2 +- .../connectors/camel-aws-kinesis-sink-sink.json| 2 +- .../camel-aws-kinesis-source-source.json | 2 +- .../connectors/camel-aws-lambda-sink-sink.json | 2 +- .../connectors/camel-aws-redshift-sink-sink.json | 2 +- .../camel-aws-redshift-source-source.json | 2 +- .../connectors/camel-aws-s3-cdc-source-source.json | 2 +- .../camel-aws-s3-experimental-source-source.json | 2 +- .../connectors/camel-aws-s3-sink-sink.json | 2 +- .../connectors/camel-aws-s3-source-source.json | 9 +--- .../camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../camel-aws-secrets-manager-sink-sink.json | 2 +- .../connectors/camel-aws-ses-sink-sink.json| 2 +- .../connectors/camel-aws-sns-fifo-sink-sink.json | 2 +- .../connectors/camel-aws-sns-sink-sink.json| 2 +- .../connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../connectors/camel-aws-sqs-fifo-sink-sink.json | 2 +- .../connectors/camel-aws-sqs-sink-sink.json| 2 +- .../connectors/camel-aws-sqs-source-source.json| 2 +- .../resources/connectors/camel-aws2-iam-sink.json | 2 +- .../resources/connectors/camel-aws2-kms-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 | 4 ++-- ...camel-azure-storage-blob-cdc-source-source.json | 6 +++--- ...zure-storage-blob-changefeed-source-source.json | 9 +--- .../camel-azure-storage-blob-sink-sink.json| 16 +-- .../camel-azure-storage-blob-source-source.json| 9 +--- .../camel-azure-storage-queue-sink-sink.json | 2 +- .../camel-azure-storage-queue-source-source.json | 2 +- .../connectors/camel-beer-source-source.json | 2 +- .../connectors/camel-bitcoin-source-source.json| 2 +- .../connectors/camel-cassandra-sink-sink.json | 10 +++-- .../connectors/camel-cassandra-source-source.json | 12 --- .../resources/connectors/camel-ceph-sink-sink.json | 2 +- .../connectors/camel-ceph-source-source.json | 2 +- .../camel-chuck-norris-source-source.json | 2 +- .../connectors/camel-couchbase-sink-sink.json | 2 +- .../connectors/camel-cron-source-source.json | 2 +- .../resources/connectors/camel-cxf-sink.json | 2 +- .../resources/connectors/camel-cxf-source.json | 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 | 4 ++-- .../connectors/camel-fhir-source-source.json | 6 +++--- .../resources/connectors/camel-file-sink.json | 2 +- .../resources/connectors/camel-file-source.json| 2 +- .../connectors/camel-file-watch-source-source.json | 2 +- .../resources/connectors/camel-ftp-sink-sink.json | 11 -- .../connectors/camel-ftp-source-source.json| 9 +++- .../resources/connectors/camel-ftps-sink-sink.json | 11 -- .../connectors/camel-ftps-source-source.json | 9 +++- .../camel-github-commit-source-source.json | 2 +- .../camel-github-event-source-source.json | 2 +- ...l-github-pullrequest-comment-sou
[camel-k] branch release-1.12.x updated: fix #4167 : Default integrationPlatform created at operator startup dose not honor OPERATOR_ID config
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch release-1.12.x in repository https://gitbox.apache.org/repos/asf/camel-k.git The following commit(s) were added to refs/heads/release-1.12.x by this push: new 937af80b9 fix #4167 : Default integrationPlatform created at operator startup dose not honor OPERATOR_ID config 937af80b9 is described below commit 937af80b98b6dc9bb923790ea9f90dc734f08858 Author: Andrea Tarocchi AuthorDate: Tue Mar 28 00:21:12 2023 +0200 fix #4167 : Default integrationPlatform created at operator startup dose not honor OPERATOR_ID config --- pkg/cmd/operator/operator.go | 13 + 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/pkg/cmd/operator/operator.go b/pkg/cmd/operator/operator.go index 69e167baf..995d916be 100644 --- a/pkg/cmd/operator/operator.go +++ b/pkg/cmd/operator/operator.go @@ -30,6 +30,7 @@ import ( "time" "github.com/pkg/errors" + "k8s.io/klog/v2" "go.uber.org/automaxprocs/maxprocs" "go.uber.org/zap" @@ -46,8 +47,6 @@ import ( "k8s.io/apimachinery/pkg/selection" "k8s.io/client-go/tools/leaderelection/resourcelock" "k8s.io/client-go/tools/record" - "k8s.io/klog/v2" - "sigs.k8s.io/controller-runtime/pkg/cache" ctrl "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client/config" @@ -243,20 +242,26 @@ func Run(healthPort, monitoringPort int32, leaderElection bool, leaderElectionID // findOrCreateIntegrationPlatform create default integration platform in operator namespace if not already exists. func findOrCreateIntegrationPlatform(ctx context.Context, c client.Client, operatorNamespace string) error { + operatorID := defaults.OperatorID() var platformName string - if defaults.OperatorID() != "" { - platformName = defaults.OperatorID() + if operatorID != "" { + platformName = operatorID } else { platformName = platform.DefaultPlatformName } if pl, err := kubernetes.GetIntegrationPlatform(ctx, c, platformName, operatorNamespace); pl == nil || k8serrors.IsNotFound(err) { defaultPlatform := v1.NewIntegrationPlatform(operatorNamespace, platformName) + if defaultPlatform.Labels == nil { defaultPlatform.Labels = make(map[string]string) } defaultPlatform.Labels["camel.apache.org/platform.generated"] = "true" + if operatorID != "" { + defaultPlatform.SetOperatorID(operatorID) + } + if _, err := c.CamelV1().IntegrationPlatforms(operatorNamespace).Create(ctx, , metav1.CreateOptions{}); err != nil { return err }
[camel-website] branch valdar-patch-1 updated (40ce3259 -> b4919d2f)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git from 40ce3259 Create release-3.20.0.md add b4919d2f Update release-3.20.0.md No new revisions were added by this update. Summary of changes: content/releases/ckc/release-3.20.0.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel-website] 01/01: Create release-3.20.0.md
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git commit 40ce325903ceb4bf0a8b007310d23efc3ae78fa0 Author: Andrea Tarocchi AuthorDate: Mon Jan 30 12:25:20 2023 +0100 Create release-3.20.0.md --- content/releases/ckc/release-3.20.0.md | 15 +++ 1 file changed, 15 insertions(+) diff --git a/content/releases/ckc/release-3.20.0.md b/content/releases/ckc/release-3.20.0.md new file mode 100644 index ..69e1cfc6 --- /dev/null +++ b/content/releases/ckc/release-3.20.0.md @@ -0,0 +1,15 @@ +--- +url: "/releases/ckc-3.20.0/" +date: 2023-01-30 +eol: 2023-12-30 +type: release-note +version: "3.20.0" +title: "Camel Kafka Connector release 3.20.0" +preview: "" +changelog: "" +category: "camel-kafka-connector" +eol: 2023-12-21 +jdk: [11,17] +--- + +This release is the new Camel Kafka Connector 3.20.0 LTS release.
[camel-website] branch valdar-patch-1 created (now 40ce3259)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git at 40ce3259 Create release-3.20.0.md This branch includes the following new commits: new 40ce3259 Create release-3.20.0.md The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
svn commit: r59696 - in /release/camel/camel-kafka-connector/3.20.0: ./ camel-kafka-connector-3.20.0-src.zip camel-kafka-connector-3.20.0-src.zip.asc camel-kafka-connector-3.20.0-src.zip.sha512
Author: valdar Date: Mon Jan 30 11:12:37 2023 New Revision: 59696 Log: Camel Kafka Connector 3.20.0 import. Added: release/camel/camel-kafka-connector/3.20.0/ release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip (with props) release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip.asc (with props) release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip.sha512 Added: release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip.sha512 == --- release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/3.20.0/camel-kafka-connector-3.20.0-src.zip.sha512 Mon Jan 30 11:12:37 2023 @@ -0,0 +1 @@ +a632fb802e3910cbbde9ea606cfa1f2ed31295eb64b0dc270fc4dd1ccf1852047346a919440200ea11a965d3e37406eeb312735535e9ec8ddbf79955b328b8c7 \ No newline at end of file
[camel-kafka-connector] branch main updated (2c6191a28 -> 7000a6257)
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 2c6191a28 chore: regen. add 894a98559 [maven-release-plugin] prepare release camel-kafka-connector-3.20.0 add 0c266c66a [maven-release-plugin] prepare for next development iteration add 7000a6257 chore: fixed formatting. No new revisions were added by this update. Summary of changes: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 3 +-- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 3 +-- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 3 +-- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudtrail-source-kafka-connector/pom.xml| 2 +- .../awscloudtrailsource/CamelAwscloudtrailsourceSourceConnector.java | 3 ++- .../CamelAwscloudtrailsourceSourceConnectorConfig.java| 3 ++- .../awscloudtrailsource/CamelAwscloudtrailsourceSourceTask.java | 3 ++- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- .../awscloudwatchsink/CamelAwscloudwatchsinkSinkConnector.java| 3 ++- .../awscloudwatchsink/CamelAwscloudwatchsinkSinkConnectorConfig.java | 3 ++- .../awscloudwatchsink/CamelAwscloudwatchsinkSinkTask.java | 3 ++- connectors/camel-aws-ddb-experimental-sink-kafka-connector/pom.xml| 2 +- .../CamelAwsddbexperimentalsinkSinkConnector.java | 3 ++- .../CamelAwsddbexperimentalsinkSinkConnectorConfig.java | 3 ++- .../awsddbexperimentalsink/CamelAwsddbexperimentalsinkSinkTask.java | 3 ++- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- .../camel/kafkaconnector/awsddbsink/CamelAwsddbsinkSinkConnector.java | 3 ++- .../kafkaconnector/awsddbsink/CamelAwsddbsinkSinkConnectorConfig.java | 3 ++- .../camel/kafkaconnector/awsddbsink/CamelAwsddbsinkSinkTask.java | 3 ++- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- .../awsddbstreamssource/CamelAwsddbstreamssourceSourceConnector.java | 3 ++- .../CamelAwsddbstreamssourceSourceConnectorConfig.java| 3 ++- .../awsddbstreamssource/CamelAwsddbstreamssourceSourceTask.java | 3 ++- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- .../camel/kafkaconnector/awsec2sink/CamelAwsec2sinkSinkConnector.java | 3 ++- .../kafkaconnector/awsec2sink/CamelAwsec2sinkSinkConnectorConfig.java | 3 ++- .../camel/kafkaconnector/awsec2sink/CamelAwsec2sinkSinkTask.java | 3 ++- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- .../awseventbridgesink/CamelAwseventbridgesinkSinkConnector.java | 3 ++- .../CamelAwseventbridgesinkSinkConnectorConfig.java | 3 ++- .../awseventbridgesink/CamelAwseventbridgesinkSinkTask.java | 3 ++- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- .../CamelAwskinesisfirehosesinkSinkConnector.java | 3 ++- .../CamelAwskinesisfirehosesinkSinkConnectorConfig.java | 3 ++- .../awskinesisfirehosesink/CamelAwskinesisfirehosesinkSinkTask.java | 3 ++- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- .../awskinesissink/CamelAwskinesissinkSinkConnector.java | 3 ++- .../awskinesissink/CamelAwskinesissinkSinkConnectorConfig.java| 3 ++- .../kafkaconnector/awskinesissink/CamelAwskinesissinkSinkTask.java| 3 ++- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- .../awskinesissource/CamelAwskinesissourceSourceConnector.java| 3 ++- .../awskinesissource/CamelAwskinesissourceSourceConnectorConfig.java | 3 ++- .../awskinesissource/CamelAwskinesissourceSourceTask.java | 3 ++- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- .../kafkaconnector/awslambdasink/CamelAwslambdasinkSinkConnector.java | 3 ++- .../awslambdasink/CamelAwslambdasinkSinkConnectorConfig.java | 3 ++- .../kafkaconnector/awslambdasink/CamelAwslambdasinkSinkTask.java | 3 ++- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- .../awsredshiftsink/CamelAwsredshiftsinkSinkConnector.java| 3 ++- .../awsredshiftsink/CamelAwsredshiftsinkSinkConnectorConfig.java | 3 ++- .../kafkaconnector/awsredshiftsink/CamelAwsredshiftsinkSinkTask.java | 3 ++- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- .../awsredshiftsource/CamelAwsredshiftsourceSourceConnector.java | 3 ++- .../CamelAwsredshiftsourceSourceConnectorConfig.java | 3
[camel-kafka-connector] tag camel-kafka-connector-3.20.0 updated (1d6d2b5e2 -> dc268c2f8)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-3.20.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git *** WARNING: tag camel-kafka-connector-3.20.0 was modified! *** from 1d6d2b5e2 (tag) to dc268c2f8 (commit) from 894a98559 [maven-release-plugin] prepare release camel-kafka-connector-3.20.0 new dc268c2f8 [after release perform chore]: regen catalog descriptors with new version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../resources/connectors/camel-aws-cloudtrail-source-source.json | 2 +- .../resources/connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-experimental-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-streams-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink-sink.json | 2 +- .../resources/connectors/camel-aws-eventbridge-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-kinesis-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-source-source.json | 2 +- .../generated/resources/connectors/camel-aws-lambda-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-redshift-sink-sink.json | 2 +- .../resources/connectors/camel-aws-redshift-source-source.json| 2 +- .../resources/connectors/camel-aws-s3-cdc-source-source.json | 2 +- .../resources/connectors/camel-aws-s3-experimental-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-s3-source-source.json| 2 +- .../resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ses-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-fifo-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sns-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-fifo-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sqs-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../resources/connectors/camel-azure-cosmosdb-source-source.json | 2 +- .../resources/connectors/camel-azure-eventhubs-sink-sink.json | 2 +- .../resources/connectors/camel-azure-eventhubs-source-source.json | 2 +- .../resources/connectors/camel-azure-functions-sink-sink.json | 2 +- .../resources/connectors/camel-azure-servicebus-sink-sink.json| 2 +- .../resources/connectors/camel-azure-servicebus-source-source.json| 2 +- .../connectors/camel-azure-storage-blob-cdc-source-source.json| 2 +- .../connectors/camel-azure-storage-blob-changefeed-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-blob-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-blob-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-queue-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-queue-source-source.json | 2 +- .../src/generated/resources/connectors/camel-beer-source-source.json | 2 +- .../generated/resources/connectors/camel-bitcoin-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cassandra-sink-sink.json | 2 +- .../generated/resources/connectors/camel-cassandra-source-source.json | 2 +- .../src/generated/resources/connectors/camel-ceph-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-ceph-source-source.json | 2 +- .../resources/connectors/camel-chuck-norris-source-source.json| 2 +- .../src/generated/resources/connectors/camel-couchbase-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-cron-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cxf-sink.json| 2 +- .../src/generated/resources/connectors/camel-cxf-source.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-sink.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-source.json| 2 +- .../src/generated/resources/connectors/camel-dropbox-sink-sink.json | 2 +- ...
[camel-kafka-connector] annotated tag camel-kafka-connector-3.20.0 created (now 1d6d2b5e2)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-3.20.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at 1d6d2b5e2 (tag) tagging 894a985599d98e4cc71112dde27d679e3d15f400 (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Thu Jan 26 12:04:06 2023 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-3.20.0 --- No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-3.20.x created (now 894a98559)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-3.20.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at 894a98559 [maven-release-plugin] prepare release camel-kafka-connector-3.20.0 This branch includes the following new commits: new 894a98559 [maven-release-plugin] prepare release camel-kafka-connector-3.20.0 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] 01/02: Updated to camel and kamelets 3.20.0
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 46b4ce448c7ac58af2a7d57b533e7ff633873d2a Author: Andrea Tarocchi AuthorDate: Tue Dec 27 16:58:12 2022 +0100 Updated to camel and kamelets 3.20.0 --- .gitignore | 1 + .../CamelStreamCacheConverterLoader.java | 52 - .../services/org/apache/camel/TypeConverterLoader | 2 - connectors/pom.xml | 1 + parent/pom.xml | 10 +-- pom.xml| 2 +- tests/itests-aws-v2/pom.xml| 2 +- .../aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 4 +- .../aws/v2/ec2/sink/CamelSinkAWSEC2ITCase.java | 4 +- .../aws/v2/iam/sink/CamelSinkAWSIAMITCase.java | 4 +- .../v2/kinesis/sink/CamelSinkAWSKinesisITCase.java | 4 +- .../source/CamelSourceAWSKinesisITCase.java| 4 +- .../aws/v2/kms/sink/CamelSinkAWSKMSITCase.java | 4 +- .../aws/v2/lambda/sink/CamelSinkLambdaITCase.java | 4 +- .../aws/v2/s3/sink/CamelSinkAWSS3ITCase.java | 4 +- .../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 4 +- .../aws/v2/sns/sink/CamelSinkAWSSNSITCase.java | 4 +- .../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 4 +- .../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 4 +- ...CloudWatchLocalContainerServiceWithTimeout.java | 23 ++ .../aws2/services/AWSContainerWithTimeout.java | 41 +++ ...WSDynamodbLocalContainerServiceWithTimeout.java | 23 ++ .../AWSEC2LocalContainerServiceWithTimeout.java| 23 ++ ...ventBridgeLocalContainerServiceWithTimeout.java | 23 ++ .../AWSIAMLocalContainerServiceWithTimeout.java| 23 ++ .../AWSKMSLocalContainerServiceWithTimeout.java| 23 ++ ...AWSKinesisLocalContainerServiceWithTimeout.java | 33 + .../AWSLambdaLocalContainerServiceWithTimeout.java | 23 ++ .../AWSS3LocalContainerServiceWithTimeout.java | 23 ++ .../AWSSNSLocalContainerServiceWithTimeout.java| 23 ++ .../AWSSQSLocalContainerServiceWithTimeout.java| 23 ++ .../AWSSTSLocalContainerServiceWithTimeout.java| 23 ++ .../services/AWSServiceFactoryWithTimeout.java | 85 ++ tests/itests-hdfs/pom.xml | 39 ++ .../hdfs/sink/CamelSinkHDFSITCase.java | 2 +- .../https/sink/CamelSinkHTTPSITCase.java | 8 +- 36 files changed, 489 insertions(+), 90 deletions(-) diff --git a/.gitignore b/.gitignore index 3663cfef1..6d71b2cd2 100644 --- a/.gitignore +++ b/.gitignore @@ -296,6 +296,7 @@ tags [._]*.un~ ### VisualStudioCode ### +.vscode/ .vscode/* !.vscode/settings.json !.vscode/tasks.json diff --git a/connectors/camel-syslog-kafka-connector/src/generated/java/org/apache/camel/kafkaconnector/syslog/converters/CamelStreamCacheConverterLoader.java b/connectors/camel-syslog-kafka-connector/src/generated/java/org/apache/camel/kafkaconnector/syslog/converters/CamelStreamCacheConverterLoader.java deleted file mode 100644 index 2fdcd612e..0 --- a/connectors/camel-syslog-kafka-connector/src/generated/java/org/apache/camel/kafkaconnector/syslog/converters/CamelStreamCacheConverterLoader.java +++ /dev/null @@ -1,52 +0,0 @@ -/* Generated by camel build tools - do NOT edit this file! */ -package org.apache.camel.kafkaconnector.syslog.converters; - -import org.apache.camel.CamelContext; -import org.apache.camel.CamelContextAware; -import org.apache.camel.DeferredContextBinding; -import org.apache.camel.Exchange; -import org.apache.camel.TypeConversionException; -import org.apache.camel.TypeConverterLoaderException; -import org.apache.camel.spi.TypeConverterLoader; -import org.apache.camel.spi.TypeConverterRegistry; -import org.apache.camel.support.SimpleTypeConverter; -import org.apache.camel.support.TypeConverterSupport; -import org.apache.camel.util.DoubleMap; - -/** - * Generated by camel build tools - do NOT edit this file! - */ -@SuppressWarnings("unchecked") -@DeferredContextBinding -public final class CamelStreamCacheConverterLoader implements TypeConverterLoader, CamelContextAware { - -private CamelContext camelContext; - -public CamelStreamCacheConverterLoader() { -} - -@Override -public void setCamelContext(CamelContext camelContext) { -this.camelContext = camelContext; -} - -@Override -public CamelContext getCamelContext() { -return camelContext; -} - -@Override -public void load(TypeConverterRegistry registry) throws TypeConverterLoaderException { -registerConverters(registry); -} - -private void registerConverters(TypeConverterRegistry registry) { -addTypeConverter(registry, io.netty.buffer.ByteBuf.class, org.apache.camel.StreamCache.cl
[camel-kafka-connector] branch main updated (78aaaa2a4 -> 2c6191a28)
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 782a4 Updated CHANGELOG.md new 46b4ce448 Updated to camel and kamelets 3.20.0 new 2c6191a28 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: .gitignore | 1 + .../resources/connectors/camel-cxf-sink.json | 7 + .../resources/connectors/camel-cxf-source.json | 7 + .../resources/connectors/camel-fhir-sink-sink.json | 108 + .../connectors/camel-google-pubsub-sink-sink.json | 6 +- .../camel-google-pubsub-source-source.json | 6 +- .../connectors/camel-google-storage-sink-sink.json | 6 +- .../camel-google-storage-source-source.json| 6 +- .../resources/connectors/camel-hdfs-sink.json | 7 +- .../resources/connectors/camel-hdfs-source.json| 7 +- .../resources/connectors/camel-https-sink.json | 10 ++ .../resources/connectors/camel-log-sink-sink.json | 7 + .../connectors/camel-slack-source-source.json | 1 + .../resources/descriptors/connectors.properties| 1 + .../kamelets/aws-cloudtrail-source.kamelet.yaml| 2 +- .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 2 +- .../pom.xml| 10 +- .../aws-ddb-experimental-sink.kamelet.yaml | 4 +- .../camel-aws-ddb-sink-kafka-connector/pom.xml | 10 +- .../resources/kamelets/aws-ddb-sink.kamelet.yaml | 4 +- .../kamelets/aws-ddb-streams-source.kamelet.yaml | 2 +- .../resources/kamelets/aws-ec2-sink.kamelet.yaml | 2 +- .../kamelets/aws-eventbridge-sink.kamelet.yaml | 2 +- .../aws-kinesis-firehose-sink.kamelet.yaml | 2 +- .../kamelets/aws-kinesis-sink.kamelet.yaml | 2 +- .../pom.xml| 10 +- .../kamelets/aws-kinesis-source.kamelet.yaml | 4 +- .../kamelets/aws-lambda-sink.kamelet.yaml | 2 +- .../pom.xml| 10 +- .../kamelets/aws-redshift-sink.kamelet.yaml| 4 +- .../pom.xml| 10 +- .../kamelets/aws-redshift-source.kamelet.yaml | 4 +- .../kamelets/aws-s3-cdc-source.kamelet.yaml| 4 +- .../pom.xml| 10 +- .../aws-s3-experimental-source.kamelet.yaml| 4 +- .../resources/kamelets/aws-s3-sink.kamelet.yaml| 2 +- .../camel-aws-s3-source-kafka-connector/pom.xml| 10 +- .../resources/kamelets/aws-s3-source.kamelet.yaml | 4 +- .../aws-s3-streaming-upload-sink.kamelet.yaml | 2 +- .../kamelets/aws-secrets-manager-sink.kamelet.yaml | 2 +- .../resources/kamelets/aws-ses-sink.kamelet.yaml | 2 +- .../kamelets/aws-sns-fifo-sink.kamelet.yaml| 2 +- .../resources/kamelets/aws-sns-sink.kamelet.yaml | 2 +- .../kamelets/aws-sqs-batch-sink.kamelet.yaml | 2 +- .../kamelets/aws-sqs-fifo-sink.kamelet.yaml| 2 +- .../resources/kamelets/aws-sqs-sink.kamelet.yaml | 2 +- .../camel-aws-sqs-source-kafka-connector/pom.xml | 10 +- .../resources/kamelets/aws-sqs-source.kamelet.yaml | 4 +- .../kamelets/azure-cosmosdb-source.kamelet.yaml| 2 +- .../kamelets/azure-eventhubs-sink.kamelet.yaml | 2 +- .../kamelets/azure-eventhubs-source.kamelet.yaml | 2 +- .../kamelets/azure-functions-sink.kamelet.yaml | 2 +- .../kamelets/azure-servicebus-sink.kamelet.yaml| 2 +- .../kamelets/azure-servicebus-source.kamelet.yaml | 2 +- .../azure-storage-blob-cdc-source.kamelet.yaml | 4 +- .../pom.xml| 14 ++ ...ure-storage-blob-changefeed-source.kamelet.yaml | 69 +++- .../kamelets/azure-storage-blob-sink.kamelet.yaml | 2 +- .../pom.xml| 10 +- .../azure-storage-blob-source.kamelet.yaml | 4 +- .../kamelets/azure-storage-queue-sink.kamelet.yaml | 2 +- .../pom.xml| 10 +- .../azure-storage-queue-source.kamelet.yaml| 4 +- .../resources/kamelets/beer-source.kamelet.yaml| 2 +- .../resources/kamelets/bitcoin-source.kamelet.yaml | 2 +- .../resources/kamelets/cassandra-sink.kamelet.yaml | 2 +- .../kamelets/cassandra-source.kamelet.yaml | 2 +- .../main/resources/kamelets/ceph-sink.kamelet.yaml | 2 +- .../resources/kamelets/ceph-source.kamelet.yaml| 2 +- .../kamelets/chuck-norris-source.kamelet.yaml | 2 +- .../resources/kamelets/couchbase-sink.kamelet.yaml | 2 +- .../resources/kamelets/cron-source.kamelet.yaml| 2 +- .../src
[camel-kafka-connector] branch main updated (c86bd40a3 -> 266af4125)
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 c86bd40a3 Bump peter-evans/create-pull-request from 4.2.0 to 4.2.3 add 266af4125 Bump actions/checkout from 3.1.0 to 3.2.0 No new revisions were added by this update. Summary of changes: .github/workflows/asf-snapshots-deploy.yml | 4 ++-- .github/workflows/automatic-changelog-update.yml | 2 +- .github/workflows/automatic-sync-camel-main.yml | 4 ++-- .github/workflows/backport.yml | 2 +- .github/workflows/ci-build.yml | 2 +- .github/workflows/daily-java-next.yml| 2 +- .github/workflows/depsreview.yaml| 2 +- .github/workflows/maven-it.yaml | 2 +- 8 files changed, 10 insertions(+), 10 deletions(-)
[camel-kafka-connector] branch main updated (9fc16548c -> c86bd40a3)
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 9fc16548c Updated CHANGELOG.md add c86bd40a3 Bump peter-evans/create-pull-request from 4.2.0 to 4.2.3 No new revisions were added by this update. Summary of changes: .github/workflows/automatic-sync-camel-main.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[camel-website] branch valdar-patch-1 updated (9b7e608d -> 72037c27)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git from 9b7e608d Created release-3.19.0.md add 72037c27 Updated ckc supported jdk No new revisions were added by this update. Summary of changes: content/releases/ckc/release-3.19.0.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
svn commit: r58789 - in /release/camel/camel-kafka-connector/3.19.0: ./ camel-kafka-connector-3.19.0-src.zip camel-kafka-connector-3.19.0-src.zip.asc camel-kafka-connector-3.19.0-src.zip.sha512
Author: valdar Date: Sat Dec 17 23:30:44 2022 New Revision: 58789 Log: Camel Kafka Connector 3.19.0 import. Added: release/camel/camel-kafka-connector/3.19.0/ release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip (with props) release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip.asc (with props) release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip.sha512 Added: release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip.sha512 == --- release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/3.19.0/camel-kafka-connector-3.19.0-src.zip.sha512 Sat Dec 17 23:30:44 2022 @@ -0,0 +1 @@ +cab67841ddfd8f9e3d13505a0445b678d27b197fd4a157e13fd3dab0043306a37448f49db01e2dff6627dfa3b70025e90a01ca4387b44f71c255c7b4587474d2 \ No newline at end of file
[camel-website] branch valdar-patch-1 created (now 9b7e608d)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git at 9b7e608d Created release-3.19.0.md No new revisions were added by this update.
[camel-kamelets] branch main updated: fixed Azure Storage Blob changefeed source connector the connector produce one record per event the connector produced data are in json format the connector add a
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git The following commit(s) were added to refs/heads/main by this push: new ea3e5ce7 fixed Azure Storage Blob changefeed source connector the connector produce one record per event the connector produced data are in json format the connector add additional info as record headers ea3e5ce7 is described below commit ea3e5ce79b1825c26bc48c84a8fd703ee4aed9d2 Author: Andrea Tarocchi AuthorDate: Fri Dec 16 10:00:23 2022 +0100 fixed Azure Storage Blob changefeed source connector the connector produce one record per event the connector produced data are in json format the connector add additional info as record headers --- ...ure-storage-blob-changefeed-source.kamelet.yaml | 68 +++--- ...ure-storage-blob-changefeed-source.kamelet.yaml | 68 +++--- 2 files changed, 122 insertions(+), 14 deletions(-) diff --git a/kamelets/azure-storage-blob-changefeed-source.kamelet.yaml b/kamelets/azure-storage-blob-changefeed-source.kamelet.yaml index a4afb7c4..aa511d84 100644 --- a/kamelets/azure-storage-blob-changefeed-source.kamelet.yaml +++ b/kamelets/azure-storage-blob-changefeed-source.kamelet.yaml @@ -66,18 +66,72 @@ spec: - "camel:azure-storage-blob" - "camel:kamelet" - "camel:core" +- 'camel:jackson' - "camel:jsonpath" - "camel:timer" +- "mvn:com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.13.4" +- "mvn:com.azure:azure-storage-blob-changefeed:12.0.0-beta.17" template: from: uri: "timer:azure-storage-blob-stream" parameters: period: "{{period}}" steps: - - to: - uri: "azure-storage-blob:{{accountName}}" - parameters: -operation: "getChangeFeed" -accessKey: "{{accessKey}}" -credentialType: "{{credentialType}}" - - to: "kamelet:sink" +- to: +uri: "azure-storage-blob:{{accountName}}" +parameters: + operation: "getChangeFeed" + accessKey: "{{accessKey}}" + credentialType: "{{credentialType}}" +- split: +expression: + simple: "${body}" +- marshal: +json: + library: Jackson + module-class-names: com.fasterxml.jackson.datatype.jsr310.JavaTimeModule + unmarshalType: com.fasterxml.jackson.databind.JsonNode +- set-header: +name: "azure-storage-blob-changefeed-topic" +jsonpath: + suppress-exceptions: true + expression: $.topic +- set-header: +name: "azure-storage-blob-changefeed-subject" +jsonpath: + suppress-exceptions: true + expression: $.subject +- set-header: +name: "azure-storage-blob-changefeed-eventType" +jsonpath: + suppress-exceptions: true + expression: $.eventType +- set-header: +name: "azure-storage-blob-changefeed-eventTime" +jsonpath: + suppress-exceptions: true + expression: $.eventTime +- set-header: +name: "azure-storage-blob-changefeed-id" +jsonpath: + suppress-exceptions: true + expression: $.id +- set-header: +name: "azure-storage-blob-changefeed-dataVersion" +jsonpath: + suppress-exceptions: true + expression: $.dataVersion +- set-header: +name: "azure-storage-blob-changefeed-metadataVersion" +jsonpath: + suppress-exceptions: true + expression: $.metadataVersion +- set-body: +jsonpath: + expression: $.data +- marshal: +json: + library: Jackson + module-class-names: com.fasterxml.jackson.datatype.jsr310.JavaTimeModule +- to: "kamelet:sink" + diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-changefeed-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-changefeed-source.kamelet.yaml index a4afb7c4..aa511d84 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-changefeed-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-changefeed-source.kamelet.yaml @@ -66,18 +66,72 @@ spec: - "camel:azure-storage-blob" - "camel:kamelet" - &q
[camel-kafka-connector] branch main updated (efaa716ef -> 75ce2a091)
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 omit efaa716ef Updated CHANGELOG.md add 0f71390c2 [maven-release-plugin] prepare release camel-kafka-connector-3.19.0 add 3e6d55ad2 [maven-release-plugin] prepare for next development iteration add b885e2ff9 chore: regen. add 75ce2a091 Updated CHANGELOG.md This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (efaa716ef) \ N -- N -- N refs/heads/main (75ce2a091) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudtrail-source-kafka-connector/pom.xml| 2 +- .../awscloudtrailsource/CamelAwscloudtrailsourceSourceConnector.java | 3 ++- .../CamelAwscloudtrailsourceSourceConnectorConfig.java| 3 ++- .../awscloudtrailsource/CamelAwscloudtrailsourceSourceTask.java | 3 ++- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- .../awscloudwatchsink/CamelAwscloudwatchsinkSinkConnector.java| 3 ++- .../awscloudwatchsink/CamelAwscloudwatchsinkSinkConnectorConfig.java | 3 ++- .../awscloudwatchsink/CamelAwscloudwatchsinkSinkTask.java | 3 ++- connectors/camel-aws-ddb-experimental-sink-kafka-connector/pom.xml| 2 +- .../CamelAwsddbexperimentalsinkSinkConnector.java | 3 ++- .../CamelAwsddbexperimentalsinkSinkConnectorConfig.java | 3 ++- .../awsddbexperimentalsink/CamelAwsddbexperimentalsinkSinkTask.java | 3 ++- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- .../camel/kafkaconnector/awsddbsink/CamelAwsddbsinkSinkConnector.java | 3 ++- .../kafkaconnector/awsddbsink/CamelAwsddbsinkSinkConnectorConfig.java | 3 ++- .../camel/kafkaconnector/awsddbsink/CamelAwsddbsinkSinkTask.java | 3 ++- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- .../awsddbstreamssource/CamelAwsddbstreamssourceSourceConnector.java | 3 ++- .../CamelAwsddbstreamssourceSourceConnectorConfig.java| 3 ++- .../awsddbstreamssource/CamelAwsddbstreamssourceSourceTask.java | 3 ++- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- .../camel/kafkaconnector/awsec2sink/CamelAwsec2sinkSinkConnector.java | 3 ++- .../kafkaconnector/awsec2sink/CamelAwsec2sinkSinkConnectorConfig.java | 3 ++- .../camel/kafkaconnector/awsec2sink/CamelAwsec2sinkSinkTask.java | 3 ++- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- .../awseventbridgesink/CamelAwseventbridgesinkSinkConnector.java | 3 ++- .../CamelAwseventbridgesinkSinkConnectorConfig.java | 3 ++- .../awseventbridgesink/CamelAwseventbridgesinkSinkTask.java | 3 ++- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- .../CamelAwskinesisfirehosesinkSinkConnector.java | 3 ++- .../CamelAwskinesisfirehosesinkSinkConnectorConfig.java | 3 ++- .../awskinesisfirehosesink/CamelAwskinesisfirehosesinkSinkTask.java | 3 ++- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- .../awskinesissink/CamelAwskinesissinkSinkConnector.java | 3 ++- .../awskinesissink/CamelAwskinesissinkSinkConnectorConfig.java| 3 ++- .../kafkaconnector/awskinesissink/CamelAwskinesissinkSinkTask.java| 3 ++- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- .../awskinesissource/CamelAwskinesissourceSourceConnector.java| 3 ++- .../awskinesissource/CamelAwskinesissourceSourceConnectorConfig.java | 3 ++- .../awskinesissource/CamelAwskinesissourceSourceTask.java | 3 ++- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- .../kafkaconnector/awslambdasink/CamelAwslambdasinkSi
[camel-kafka-connector] tag camel-kafka-connector-3.19.0 updated (c9fc148bb -> 343dbf6ea)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-3.19.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git *** WARNING: tag camel-kafka-connector-3.19.0 was modified! *** from c9fc148bb (tag) to 343dbf6ea (commit) from 0f71390c2 [maven-release-plugin] prepare release camel-kafka-connector-3.19.0 new 343dbf6ea [after release perform chore]: regen catalog descriptors with new version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../resources/connectors/camel-aws-cloudtrail-source-source.json | 4 ++-- .../resources/connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-experimental-sink-sink.json| 4 ++-- .../src/generated/resources/connectors/camel-aws-ddb-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-streams-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink-sink.json | 2 +- .../resources/connectors/camel-aws-eventbridge-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-kinesis-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-source-source.json | 2 +- .../generated/resources/connectors/camel-aws-lambda-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-redshift-sink-sink.json | 2 +- .../resources/connectors/camel-aws-redshift-source-source.json| 2 +- .../resources/connectors/camel-aws-s3-cdc-source-source.json | 4 ++-- .../resources/connectors/camel-aws-s3-experimental-source-source.json | 4 ++-- .../src/generated/resources/connectors/camel-aws-s3-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-s3-source-source.json| 2 +- .../resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ses-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-fifo-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sns-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-fifo-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sqs-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../resources/connectors/camel-azure-cosmosdb-source-source.json | 2 +- .../resources/connectors/camel-azure-eventhubs-sink-sink.json | 2 +- .../resources/connectors/camel-azure-eventhubs-source-source.json | 2 +- .../resources/connectors/camel-azure-functions-sink-sink.json | 2 +- .../resources/connectors/camel-azure-servicebus-sink-sink.json| 2 +- .../resources/connectors/camel-azure-servicebus-source-source.json| 2 +- .../connectors/camel-azure-storage-blob-cdc-source-source.json| 4 ++-- .../connectors/camel-azure-storage-blob-changefeed-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-blob-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-blob-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-queue-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-queue-source-source.json | 2 +- .../src/generated/resources/connectors/camel-beer-source-source.json | 2 +- .../generated/resources/connectors/camel-bitcoin-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cassandra-sink-sink.json | 2 +- .../generated/resources/connectors/camel-cassandra-source-source.json | 2 +- .../src/generated/resources/connectors/camel-ceph-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-ceph-source-source.json | 2 +- .../resources/connectors/camel-chuck-norris-source-source.json| 2 +- .../src/generated/resources/connectors/camel-couchbase-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-cron-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cxf-sink.json| 2 +- .../src/generated/resources/connectors/camel-cxf-source.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-sink.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-source.json| 2 +- .../src/generated/resources/connectors/camel-dropbox-sink-sink.json |
[camel-kafka-connector] branch camel-kafka-connector-3.19.x updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.19.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-3.19.x by this push: new 3e6d55ad2 [maven-release-plugin] prepare for next development iteration 3e6d55ad2 is described below commit 3e6d55ad237b3aefe0c75ecfb203eebde4c6a78f Author: Andrea Tarocchi AuthorDate: Wed Dec 14 00:17:04 2022 +0100 [maven-release-plugin] prepare for next development iteration --- .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudtrail-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-experimental-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-cdc-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-experimental-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-functions-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-servicebus-sink-kafka-connector/pom.xml| 2 +- connectors/camel-azure-servicebus-source-kafka-connector/pom.xml | 2 +- .../camel-azure-storage-blob-cdc-source-kafka-connector/pom.xml | 2 +- .../pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-beer-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-ceph-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ceph-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka
[camel-kafka-connector] branch camel-kafka-connector-3.19.x created (now 0f71390c2)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-3.19.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at 0f71390c2 [maven-release-plugin] prepare release camel-kafka-connector-3.19.0 This branch includes the following new commits: new 0f71390c2 [maven-release-plugin] prepare release camel-kafka-connector-3.19.0 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] 01/01: [maven-release-plugin] prepare release camel-kafka-connector-3.19.0
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.19.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 0f71390c277ca61b5fec9f619fc70edc0a91331d Author: Andrea Tarocchi AuthorDate: Wed Dec 14 00:16:55 2022 +0100 [maven-release-plugin] prepare release camel-kafka-connector-3.19.0 --- .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudtrail-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-experimental-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-cdc-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-experimental-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-functions-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-servicebus-sink-kafka-connector/pom.xml| 2 +- connectors/camel-azure-servicebus-source-kafka-connector/pom.xml | 2 +- .../camel-azure-storage-blob-cdc-source-kafka-connector/pom.xml | 2 +- .../pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-beer-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-ceph-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ceph-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml| 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml
[camel-kafka-connector] annotated tag camel-kafka-connector-3.19.0 created (now c9fc148bb)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-3.19.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at c9fc148bb (tag) tagging 0f71390c277ca61b5fec9f619fc70edc0a91331d (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Wed Dec 14 00:17:00 2022 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-3.19.0 --- No new revisions were added by this update.
[camel-kafka-connector] branch main updated: Removed staging repositories after Camel 3.19 release.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new b8ffc1727 Removed staging repositories after Camel 3.19 release. b8ffc1727 is described below commit b8ffc172754d4c58850591eda60984f10d8dd14d Author: Andrea Tarocchi AuthorDate: Tue Dec 13 22:18:53 2022 +0100 Removed staging repositories after Camel 3.19 release. --- parent/pom.xml | 21 - .../pom.xml| 22 -- .../maven_project/pom.xml | 22 -- 3 files changed, 65 deletions(-) diff --git a/parent/pom.xml b/parent/pom.xml index caa314d64..d30491fc3 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -78,17 +78,6 @@ false - -apache.camel.kamelets - https://repository.apache.org/content/repositories/orgapachecamel-1500 -Apache Camel Kamelet Staging Repo - -true - - -true - - @@ -101,16 +90,6 @@ false - -apache.camel.kamelets - https://repository.apache.org/content/repositories/orgapachecamel-1500 - -true - - -false - - diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/pom.xml b/tooling/camel-kafka-connector-generator-maven-plugin/pom.xml index 62a8f0af9..dce010599 100644 --- a/tooling/camel-kafka-connector-generator-maven-plugin/pom.xml +++ b/tooling/camel-kafka-connector-generator-maven-plugin/pom.xml @@ -72,17 +72,6 @@ false - -apache.camel.kamelets - https://repository.apache.org/content/repositories/orgapachecamel-1500 -Apache Camel Kamelet Staging Repo - -true - - -true - - @@ -121,17 +110,6 @@ false - -apache.camel.kamelets - https://repository.apache.org/content/repositories/orgapachecamel-1500 -Apache Camel Kamelet Staging Repo - -true - - -true - - diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml b/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml index af393bbe6..4503d230a 100644 --- a/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml +++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml @@ -69,17 +69,6 @@ false - -apache.camel.kamelets - https://repository.apache.org/content/repositories/orgapachecamel-1500 -Apache Camel Kamelet Staging Repo - -true - - -true - - @@ -118,17 +107,6 @@ false - -apache.camel.kamelets - https://repository.apache.org/content/repositories/orgapachecamel-1500 -Apache Camel Kamelet Staging Repo - -true - - -true - -
[camel-kafka-connector] 04/04: chore: regen.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit e3122a7ae811cd218dc6a6e0fd93a2c358b1345e Author: Andrea Tarocchi AuthorDate: Thu Dec 8 00:36:56 2022 +0100 chore: regen. --- .../camel-aws-cloudtrail-source-source.json| 64 +++ .../camel-aws-ddb-experimental-sink-sink.json | 78 .../connectors/camel-aws-s3-cdc-source-source.json | 105 +++ .../camel-aws-s3-experimental-source-source.json | 105 +++ ...camel-azure-storage-blob-cdc-source-source.json | 70 +++ .../camel-google-storage-cdc-source-source.json| 65 +++ .../resources/descriptors/connectors.properties| 1 - .../pom.xml| 151 --- .../descriptors/connector-source.properties| 1 - ...s-exchange-online-imap-oauth-source-source.json | 65 --- .../src/main/assembly/package.xml | 56 -- ...onlineimapoauthsourceSourceConnector.properties | 38 ...changeonlineimapoauthsourceSourceConnector.java | 36 ...onlineimapoauthsourceSourceConnectorConfig.java | 76 ...lMsexchangeonlineimapoauthsourceSourceTask.java | 38 .../src/main/resources/META-INF/LICENSE.txt| 203 - .../src/main/resources/META-INF/NOTICE.txt | 11 -- ...-exchange-online-imap-oauth-source.kamelet.yaml | 105 --- docs/modules/ROOT/nav.adoc | 2 - docs/modules/ROOT/pages/reference/index.adoc | 3 +- 20 files changed, 488 insertions(+), 785 deletions(-) diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-cloudtrail-source-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-cloudtrail-source-source.json new file mode 100644 index 0..21500b256 --- /dev/null +++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-cloudtrail-source-source.json @@ -0,0 +1,64 @@ +{ + "connector": { + "class": "org.apache.camel.kafkaconnector.awscloudtrailsource.CamelAwscloudtrailsourceSourceConnector", + "artifactId": "camel-aws-cloudtrail-source-kafka-connector", + "groupId": "org.apache.camel.kafkaconnector", + "id": "camel-aws-cloudtrail-source-source", + "type": "source", + "version": "3.19.0-SNAPSHOT", + "description": "Receive data from an AWS Cloudtrail.\n\nThe basic authentication method for the Cloudtrail service is to specify an access key and a secret key. These parameters are optional because the Kamelet provides a default credentials provider." + }, + "properties": { + "camel.kamelet.aws-cloudtrail-source.accessKey": { + "name": "camel.kamelet.aws-cloudtrail-source.accessKey", + "description": "The access key obtained from AWS.", + "priority": "MEDIUM", + "required": "false" + }, + "camel.kamelet.aws-cloudtrail-source.secretKey": { + "name": "camel.kamelet.aws-cloudtrail-source.secretKey", + "description": "The secret key obtained from AWS.", + "priority": "MEDIUM", + "required": "false" + }, + "camel.kamelet.aws-cloudtrail-source.region": { + "name": "camel.kamelet.aws-cloudtrail-source.region", + "description": "The AWS region to access.", + "priority": "HIGH", + "required": "true" + }, + "camel.kamelet.aws-cloudtrail-source.useDefaultCredentialsProvider": { + "name": "camel.kamelet.aws-cloudtrail-source.useDefaultCredentialsProvider", + "description": "If true, the Cloudtrail client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).", + "defaultValue": "false", + "priority": "MEDIUM", + "required": "false" + }, + "camel.kamelet.aws-cl
[camel-kafka-connector] 01/04: Point Camel Kamelets 0.10.0
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 8c1714d60a126d9751580d9096054849314ef227 Author: Andrea Cosentino AuthorDate: Tue Dec 6 18:27:33 2022 +0100 Point Camel Kamelets 0.10.0 Signed-off-by: Andrea Cosentino --- parent/pom.xml | 23 ++- 1 file changed, 22 insertions(+), 1 deletion(-) diff --git a/parent/pom.xml b/parent/pom.xml index 15ffd3f7f..720c59b77 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -29,7 +29,7 @@ 2.8.0 3.19.0 -0.9.1 +0.10.0 1.3.2.Final 4.5.6.Final 11 @@ -78,6 +78,17 @@ false + +apache.camel.kamelets + https://repository.apache.org/content/repositories/orgapachecamel-1500 +Apache Camel Kamelet Staging Repo + +true + + +false + + @@ -90,6 +101,16 @@ false + +apache.camel.kamelets + https://repository.apache.org/content/repositories/orgapachecamel-1500 + +true + + +false + +
[camel-kafka-connector] 03/04: Fixed tests and dependencies for camel 3.19 and kamelets catalog 0.10.0
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit c1e5b4052dd6af4a1595540614bd6f6503424be2 Author: Andrea Tarocchi AuthorDate: Thu Dec 8 00:36:36 2022 +0100 Fixed tests and dependencies for camel 3.19 and kamelets catalog 0.10.0 --- connectors/pom.xml | 1 - parent/pom.xml | 2 +- tests/itests-aws-v2/pom.xml| 6 ++ tests/itests-azure-storage-queue/pom.xml | 6 ++ .../pom.xml| 98 ++ .../maven_project/pom.xml | 71 6 files changed, 182 insertions(+), 2 deletions(-) diff --git a/connectors/pom.xml b/connectors/pom.xml index 81e7e9b33..97a99ae85 100644 --- a/connectors/pom.xml +++ b/connectors/pom.xml @@ -336,7 +336,6 @@ camel-mqtt-source-kafka-connector camel-mqtt5-sink-kafka-connector camel-mqtt5-source-kafka-connector - camel-ms-exchange-online-imap-oauth-source-kafka-connector camel-mysql-sink-kafka-connector camel-mysql-source-kafka-connector camel-nats-sink-kafka-connector diff --git a/parent/pom.xml b/parent/pom.xml index 720c59b77..caa314d64 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -86,7 +86,7 @@ true -false +true diff --git a/tests/itests-aws-v2/pom.xml b/tests/itests-aws-v2/pom.xml index 8db842264..7c5dad019 100644 --- a/tests/itests-aws-v2/pom.xml +++ b/tests/itests-aws-v2/pom.xml @@ -102,6 +102,12 @@ org.apache.camel camel-gson + + + org.apache.camel.kamelets +camel-kamelets-utils +${camel.kamelet.catalog.version} + diff --git a/tests/itests-azure-storage-queue/pom.xml b/tests/itests-azure-storage-queue/pom.xml index f78ac51b0..140ab943b 100644 --- a/tests/itests-azure-storage-queue/pom.xml +++ b/tests/itests-azure-storage-queue/pom.xml @@ -60,6 +60,12 @@ camel-azure-storage-queue + + org.apache.camel.kamelets +camel-kamelets-utils +${camel.kamelet.catalog.version} + + org.apache.camel diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/pom.xml b/tooling/camel-kafka-connector-generator-maven-plugin/pom.xml index 2c102eee8..62a8f0af9 100644 --- a/tooling/camel-kafka-connector-generator-maven-plugin/pom.xml +++ b/tooling/camel-kafka-connector-generator-maven-plugin/pom.xml @@ -36,6 +36,104 @@ 4.8.110 + + + +atlassian-public +https://packages.atlassian.com/maven-external +Atlassian Public Repo + +false + + +true + + + + +jboss.thirdparty +JBoss Thirdparty Repository + https://repository.jboss.org/nexus/service/local/repositories/thirdparty-releases/content/ + +false + + +true + + + +apache.snapshots +https://repository.apache.org/snapshots/ +Apache Snapshot Repo + +true + + +false + + + +apache.camel.kamelets + https://repository.apache.org/content/repositories/orgapachecamel-1500 +Apache Camel Kamelet Staging Repo + +true + + +true + + + + + + + +atlassian-public +https://packages.atlassian.com/maven-external +Atlassian Public Repo + +false + + +true + + + + +jboss.thirdparty +JBoss Thirdparty Repository + https://repository.jboss.org/nexus/service/local/repositories/thirdparty-releases/content/ + +false + + +true + + + +apache.snapshots +https://repository.apache.org/snapshots/ +Apache Snapshot Repo + +true + + +false + + + +apache.camel.kamelets + https://repository.apache.org/content/repositories/orgapachecamel-1500 +Apache Camel Kamelet Staging Repo + +true + + +true
[camel-kafka-connector] branch main updated (6e352610a -> e3122a7ae)
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 6e352610a Updated CHANGELOG.md new 8c1714d60 Point Camel Kamelets 0.10.0 new 6b3715bde Aligned CKC to Camel-Kamelets 0.10.0 new c1e5b4052 Fixed tests and dependencies for camel 3.19 and kamelets catalog 0.10.0 new e3122a7ae 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: .../camel-aws-cloudtrail-source-source.json| 64 ++ ...n => camel-aws-ddb-experimental-sink-sink.json} | 53 ++--- .../camel-aws-kinesis-source-source.json | 2 +- .../connectors/camel-aws-s3-cdc-source-source.json | 105 ++ ...> camel-aws-s3-experimental-source-source.json} | 69 --- .../connectors/camel-aws-s3-source-source.json | 2 +- .../connectors/camel-aws-sqs-source-source.json| 9 +- .../camel-azure-eventhubs-sink-sink.json | 2 +- ...camel-azure-storage-blob-cdc-source-source.json | 70 +++ ...zure-storage-blob-changefeed-source-source.json | 7 + .../camel-azure-storage-blob-source-source.json| 23 ++- .../camel-azure-storage-queue-source-source.json | 2 +- .../camel-chuck-norris-source-source.json | 2 +- .../resources/connectors/camel-ftp-sink-sink.json | 7 + .../connectors/camel-ftp-source-source.json| 7 + .../resources/connectors/camel-ftps-sink-sink.json | 7 + .../connectors/camel-ftps-source-source.json | 7 + .../camel-google-functions-sink-sink.json | 2 +- .../camel-google-storage-cdc-source-source.json| 65 ++ .../camel-kafka-not-secured-sink-sink.json | 2 +- .../connectors/camel-kafka-ssl-source-source.json | 14 +- .../resources/connectors/camel-log-sink-sink.json | 69 +++ .../resources/connectors/camel-mail-sink-sink.json | 7 - .../connectors/camel-mariadb-source-source.json| 7 + .../connectors/camel-mysql-source-source.json | 7 + .../connectors/camel-postgresql-source-source.json | 7 + .../connectors/camel-salesforce-source-source.json | 35 .../resources/connectors/camel-scp-sink-sink.json | 26 +++ .../resources/connectors/camel-sftp-sink-sink.json | 47 - .../connectors/camel-sftp-source-source.json | 47 - .../connectors/camel-sqlserver-sink-sink.json | 14 ++ .../connectors/camel-sqlserver-source-source.json | 21 ++ .../connectors/camel-timer-source-source.json | 6 + .../resources/descriptors/connectors.properties| 6 + .../pom.xml| 14 +- .../descriptors/connector-source.properties| 1 + .../camel-aws-cloudtrail-source-source.json| 64 ++ .../src/main/assembly/package.xml | 0 ...lAwscloudtrailsourceSourceConnector.properties} | 6 +- .../CamelAwscloudtrailsourceSourceConnector.java} | 9 +- ...elAwscloudtrailsourceSourceConnectorConfig.java | 76 +++ .../CamelAwscloudtrailsourceSourceTask.java} | 9 +- .../src/main/resources/META-INF/LICENSE.txt| 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kamelets/aws-cloudtrail-source.kamelet.yaml| 90 + .../pom.xml| 5 - .../CamelAwscloudwatchsinkSinkConnector.java | 3 +- .../CamelAwscloudwatchsinkSinkConnectorConfig.java | 3 +- .../CamelAwscloudwatchsinkSinkTask.java| 3 +- .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 3 +- .../pom.xml| 17 +- .../descriptors/connector-sink.properties | 1 + .../camel-aws-ddb-experimental-sink-sink.json | 53 ++--- .../src/main/assembly/package.xml | 0 ...AwsddbexperimentalsinkSinkConnector.properties} | 8 +- .../CamelAwsddbexperimentalsinkSinkConnector.java} | 9 +- ...lAwsddbexperimentalsinkSinkConnectorConfig.java | 84 .../CamelAwsddbexperimentalsinkSinkTask.java} | 9 +- .../src/main/resources/META-INF/LICENSE.txt| 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../aws-ddb-experimental-sink.kamelet.yaml}| 40 ++-- .../camel-aws-ddb-sink-kafka-connector/pom.xml | 11 +- .../awsddbsink/CamelAwsddbsinkSinkConnector.java | 3 +- .../CamelAwsddbsinkSinkConnectorConfig.java| 3 +- .../awsddbsink/CamelAwsddbsinkSinkTask.java| 3 +- .../resources/kamelets/aws-ddb-sink.kamelet.yaml | 5 +- .../pom.xml| 5 - .../CamelAwsddbstreamssourceSourceConnector.java | 3 +- ...elAwsddbstreamssourceSourceConnectorConfig.java | 3 +- .../CamelAwsddbst
[camel-kafka-connector] branch camel-kamelets-0.10.0 updated (3d7705408 -> 1e5f542c2)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kamelets-0.10.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git omit 3d7705408 chore: regen. omit d5899377f Fixed tests and dependencies for camel 3.19 and kamelets catalog 0.10.0 add 9278a3d39 Fixed tests and dependencies for camel 3.19 and kamelets catalog 0.10.0 add 1e5f542c2 chore: regen. This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (3d7705408) \ N -- N -- N refs/heads/camel-kamelets-0.10.0 (1e5f542c2) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .../pom.xml| 98 ++ .../maven_project/pom.xml | 71 2 files changed, 169 insertions(+)
[camel-kafka-connector] branch camel-kamelets-0.10.0 updated (13f33af1e -> 3d7705408)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kamelets-0.10.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git omit 13f33af1e Aligned CKC to Camel-Kamelets 0.10.0 omit eac1a0577 Point Camel Kamelets 0.10.0 add a7f65cf3a Updated CHANGELOG.md add fa3982c3e Added exlusion of kamelets generation. add 8d9a04e9b Point Camel Kamelets 0.10.0 add e1443668c Aligned CKC to Camel-Kamelets 0.10.0 add d5899377f Fixed tests and dependencies for camel 3.19 and kamelets catalog 0.10.0 add 3d7705408 chore: regen. This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (13f33af1e) \ N -- N -- N refs/heads/camel-kamelets-0.10.0 (3d7705408) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: CHANGELOG.md | 4 + .../camel-aws-cloudtrail-source-source.json| 0 .../camel-aws-ddb-experimental-sink-sink.json | 0 .../camel-aws-s3-cdc-source-source.json| 0 .../camel-aws-s3-experimental-source-source.json | 0 ...camel-azure-storage-blob-cdc-source-source.json | 0 .../camel-google-storage-cdc-source-source.json| 0 .../resources/descriptors/connectors.properties| 1 - .../pom.xml| 151 --- .../descriptors/connector-source.properties| 1 - ...s-exchange-online-imap-oauth-source-source.json | 65 --- .../src/main/assembly/package.xml | 56 -- ...onlineimapoauthsourceSourceConnector.properties | 38 ...changeonlineimapoauthsourceSourceConnector.java | 36 ...onlineimapoauthsourceSourceConnectorConfig.java | 76 ...lMsexchangeonlineimapoauthsourceSourceTask.java | 38 .../src/main/resources/META-INF/LICENSE.txt| 203 - .../src/main/resources/META-INF/NOTICE.txt | 11 -- ...-exchange-online-imap-oauth-source.kamelet.yaml | 105 --- connectors/pom.xml | 4 +- docs/modules/ROOT/nav.adoc | 2 - docs/modules/ROOT/pages/reference/index.adoc | 3 +- parent/pom.xml | 2 +- tests/itests-aws-v2/pom.xml| 6 + tests/itests-azure-storage-queue/pom.xml | 6 + .../maven/GenerateCamelKafkaConnectorsMojo.java| 14 +- .../maven_project/pom.xml | 3 + 27 files changed, 34 insertions(+), 791 deletions(-) copy {connectors/camel-aws-cloudtrail-source-kafka-connector/src/generated/resources => camel-kafka-connector-catalog/src/generated/resources/connectors}/camel-aws-cloudtrail-source-source.json (100%) copy {connectors/camel-aws-ddb-experimental-sink-kafka-connector/src/generated/resources => camel-kafka-connector-catalog/src/generated/resources/connectors}/camel-aws-ddb-experimental-sink-sink.json (100%) copy {connectors/camel-aws-s3-cdc-source-kafka-connector/src/generated/resources => camel-kafka-connector-catalog/src/generated/resources/connectors}/camel-aws-s3-cdc-source-source.json (100%) copy {connectors/camel-aws-s3-experimental-source-kafka-connector/src/generated/resources => camel-kafka-connector-catalog/src/generated/resources/connectors}/camel-aws-s3-experimental-source-source.json (100%) copy {connectors/camel-azure-storage-blob-cdc-source-kafka-connector/src/generated/resources => camel-kafka-connector-catalog/src/generated/resources/connectors}/camel-azure-storage-blob-cdc-source-source.json (100%) copy {connectors/camel-google-storage-cdc-source-kafka-connector/src/generated/resources => camel-kafka-connector-catalog/src/generated/resources/connectors}/camel-google-storage-cdc-source-source.json (100%) delete mode 100644 connectors/camel-ms-exchange-online-imap-oauth-source-kafka-connector/pom.xml delete mode 100644 connectors/camel-ms-exchange-online-imap-oauth-source-kafka-connector/src/generated/descriptors/connector-source.properties delete mode 100644 connectors/camel-ms-exchange-online-imap-oauth-source-kafka-connector/src/generated/resources/camel-ms-exchange-online-imap-oauth-source-source.json delete mode 100644 connectors/camel-ms-exchange-online-imap-oauth-source-kafka-connector/src/main/assembly/package.xml delete mod
[camel-kafka-connector] branch main updated: Added exlusion of kamelets generation.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new fa3982c3e Added exlusion of kamelets generation. fa3982c3e is described below commit fa3982c3e6954420ff9f0d8887afd91903bfdc61 Author: Andrea Tarocchi AuthorDate: Wed Dec 7 14:02:01 2022 +0100 Added exlusion of kamelets generation. --- connectors/pom.xml | 3 +++ .../maven/GenerateCamelKafkaConnectorsMojo.java| 14 ++ .../maven_project/pom.xml | 3 +++ 3 files changed, 16 insertions(+), 4 deletions(-) diff --git a/connectors/pom.xml b/connectors/pom.xml index 839b88516..091bcd414 100644 --- a/connectors/pom.xml +++ b/connectors/pom.xml @@ -104,6 +104,9 @@ ${project.basedir}/camel-kafka-connector-template-example-sink-properties.template true + +ms-exchange-online-imap-oauth-source + bonita bean-validator diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java index 275469dc6..efbe5d900 100644 --- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java +++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojo.java @@ -148,6 +148,12 @@ public class GenerateCamelKafkaConnectorsMojo extends AbstractCamelKafkaConnecto @Parameter(defaultValue = "", readonly = true) private List excludedComponents = Collections.EMPTY_LIST; +/** + * The Camel Kamelets Exclusion List to select for which kamelet must be skipped while generating kafka connector. + */ +@Parameter(defaultValue = "", readonly = true) +private List excludedKamelets = Collections.EMPTY_LIST; + /** * The Exclusion List of connectors that must be skipped while deleting kafka connector. */ @@ -187,8 +193,8 @@ public class GenerateCamelKafkaConnectorsMojo extends AbstractCamelKafkaConnecto .collect(Collectors.joining("\n")); KameletModel kameletModel = YamlKameletMapper.parseKameletYaml(kamelet); -// filter all kamelets with type not in {source,sink} -if ("source".equals(kameletModel.getType()) || "sink".equals(kameletModel.getType())) { +// filter all kamelets with type not in {source,sink} and not excluded +if (("source".equals(kameletModel.getType()) || "sink".equals(kameletModel.getType())) && !excludedKamelets.contains(kameletModel.getName())) { kameletsResources.put(kameletModel.getName(), kamelet); camelComponentsUsedInKamelets.addAll( kameletModel.getDependencies().stream() @@ -197,9 +203,9 @@ public class GenerateCamelKafkaConnectorsMojo extends AbstractCamelKafkaConnecto .collect(Collectors.toSet()) ); } -//TODO: add include (filter) / exclude mechanism -getLog().info("Kamelets found to be used to generate/update a kafka connector: " + kameletsResources.keySet()); +//TODO: add include (filter) } +getLog().info("Kamelets found to be used to generate/update a kafka connector: " + kameletsResources.keySet()); for (String kamelet : kameletsResources.keySet()) { executeMojo( diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml b/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml index a3816c1bf..e67cf7350 100644 --- a/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml +++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/test/resources-its/org/apache/camel/kafkaconnector/maven/GenerateCamelKafkaConnectorsMojoIT/maven_project/pom.xml @@ -115,6 +115,9 @@ ${project.build.testOutputDirectory}/camel-kafka-c
[camel-kafka-connector] branch main updated (07013f7e8 -> 6f9f99379)
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 07013f7e8 Updated CHANGELOG.md new 245ffbdf0 Updated doc for latest release. new 58540c6bd Fixed tests. new 6f9f99379 chore: regen. The 3 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-aws-s3-streaming-upload-sink-sink.json | 7 - .../camel-azure-storage-blob-sink-sink.json| 7 + .../camel-azure-storage-blob-source-source.json| 7 + .../camel-google-bigquery-sink-sink.json | 6 +- .../camel-google-storage-source-source.json| 2 +- .../connectors/camel-mongodb-source-source.json| 2 +- .../connectors/camel-rabbitmq-source-source.json | 7 + .../pom.xml| 5 + .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 5 +- .../camel-aws-ddb-sink-kafka-connector/pom.xml | 11 +- .../resources/kamelets/aws-ddb-sink.kamelet.yaml | 7 +- .../pom.xml| 5 + .../kamelets/aws-ddb-streams-source.kamelet.yaml | 5 +- .../camel-aws-ec2-sink-kafka-connector/pom.xml | 5 + .../resources/kamelets/aws-ec2-sink.kamelet.yaml | 5 +- .../pom.xml| 5 + .../kamelets/aws-eventbridge-sink.kamelet.yaml | 5 +- .../pom.xml| 5 + .../aws-kinesis-firehose-sink.kamelet.yaml | 5 +- .../camel-aws-kinesis-sink-kafka-connector/pom.xml | 5 + .../kamelets/aws-kinesis-sink.kamelet.yaml | 5 +- .../pom.xml| 5 + .../kamelets/aws-kinesis-source.kamelet.yaml | 5 +- .../camel-aws-lambda-sink-kafka-connector/pom.xml | 5 + .../kamelets/aws-lambda-sink.kamelet.yaml | 5 +- .../kamelets/aws-redshift-sink.kamelet.yaml| 2 +- .../kamelets/aws-redshift-source.kamelet.yaml | 2 +- .../camel-aws-s3-sink-kafka-connector/pom.xml | 5 + .../resources/kamelets/aws-s3-sink.kamelet.yaml| 5 +- .../camel-aws-s3-source-kafka-connector/pom.xml| 5 + .../resources/kamelets/aws-s3-source.kamelet.yaml | 5 +- .../pom.xml| 5 + .../camel-aws-s3-streaming-upload-sink-sink.json | 7 - ...wss3streaminguploadsinkSinkConnectorConfig.java | 4 - .../aws-s3-streaming-upload-sink.kamelet.yaml | 14 +- .../pom.xml| 5 + .../kamelets/aws-secrets-manager-sink.kamelet.yaml | 5 +- .../camel-aws-ses-sink-kafka-connector/pom.xml | 5 + .../resources/kamelets/aws-ses-sink.kamelet.yaml | 5 +- .../pom.xml| 5 + .../kamelets/aws-sns-fifo-sink.kamelet.yaml| 5 +- .../camel-aws-sns-sink-kafka-connector/pom.xml | 5 + .../resources/kamelets/aws-sns-sink.kamelet.yaml | 5 +- .../pom.xml| 5 + .../kamelets/aws-sqs-batch-sink.kamelet.yaml | 5 +- .../pom.xml| 5 + .../kamelets/aws-sqs-fifo-sink.kamelet.yaml| 5 +- .../camel-aws-sqs-sink-kafka-connector/pom.xml | 5 + .../resources/kamelets/aws-sqs-sink.kamelet.yaml | 5 +- .../camel-aws-sqs-source-kafka-connector/pom.xml | 5 + .../resources/kamelets/aws-sqs-source.kamelet.yaml | 5 +- .../kamelets/azure-cosmosdb-source.kamelet.yaml| 2 +- .../kamelets/azure-eventhubs-sink.kamelet.yaml | 2 +- .../kamelets/azure-eventhubs-source.kamelet.yaml | 2 +- .../kamelets/azure-functions-sink.kamelet.yaml | 2 +- .../kamelets/azure-servicebus-sink.kamelet.yaml| 2 +- .../kamelets/azure-servicebus-source.kamelet.yaml | 2 +- ...ure-storage-blob-changefeed-source.kamelet.yaml | 2 +- .../camel-azure-storage-blob-sink-sink.json| 7 + ...melAzurestorageblobsinkSinkConnectorConfig.java | 4 + .../kamelets/azure-storage-blob-sink.kamelet.yaml | 10 +- .../camel-azure-storage-blob-source-source.json| 7 + ...zurestorageblobsourceSourceConnectorConfig.java | 4 + .../azure-storage-blob-source.kamelet.yaml | 8 +- .../kamelets/azure-storage-queue-sink.kamelet.yaml | 2 +- .../azure-storage-queue-source.kamelet.yaml| 2 +- .../resources/kamelets/beer-source.kamelet.yaml| 2 +- .../resources/kamelets/bitcoin-source.kamelet.yaml | 2 +- .../resources/kamelets/cassandra-sink.kamelet.yaml | 2 +- .../kamelets/cassandra-source.kamelet.yaml | 2 +- .../main/resources/kamelets/ceph-sink.kamelet.yaml | 2 +- .../resources/kamelets/ceph-source.kamelet.yaml| 2 +- .../k
[camel-kafka-connector] 02/03: Fixed tests.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 58540c6bd631dddfc6b0507dc09482fd7ab16cb9 Author: Andrea Tarocchi AuthorDate: Fri Oct 28 18:34:07 2022 +0200 Fixed tests. --- .../aws/v2/clients/AWSSQSClient.java | 2 ++ .../aws/v2/sns/sink/CamelSinkAWSSNSITCase.java | 2 +- .../couchbase/sink/CamelSinkCouchbaseITCase.java | 31 ++ 3 files changed, 23 insertions(+), 12 deletions(-) diff --git a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/clients/AWSSQSClient.java b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/clients/AWSSQSClient.java index cad0fee33..b4c0d33c8 100644 --- a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/clients/AWSSQSClient.java +++ b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/clients/AWSSQSClient.java @@ -62,6 +62,8 @@ public class AWSSQSClient { .queueName(queue) .build(); +LOG.debug("Queue: {} QueueName: {} createFifoQueueRequest: {}", queue, createFifoQueueRequest.queueName(), createFifoQueueRequest); + CreateQueueResponse response = sqs.createQueue(createFifoQueueRequest); if (response.sdkHttpResponse().isSuccessful()) { diff --git a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sns/sink/CamelSinkAWSSNSITCase.java b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sns/sink/CamelSinkAWSSNSITCase.java index 2389a47be..b3408d7da 100644 --- a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sns/sink/CamelSinkAWSSNSITCase.java +++ b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sns/sink/CamelSinkAWSSNSITCase.java @@ -115,7 +115,7 @@ public class CamelSinkAWSSNSITCase extends CamelSinkTestSupport { protected void consumeMessages(CountDownLatch latch) { try { -awsSqsClient.receive(sqsQueueUrl, this::checkMessages); +awsSqsClient.receive(queueName, this::checkMessages); } catch (Throwable t) { LOG.error("Failed to consume messages: {}", t.getMessage(), t); fail(t.getMessage()); diff --git a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java index 25dc25ce3..4fff797ea 100644 --- a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java +++ b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java @@ -43,6 +43,7 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.TestInstance; import org.junit.jupiter.api.Timeout; +import org.junit.jupiter.api.condition.EnabledIfSystemProperty; import org.junit.jupiter.api.extension.RegisterExtension; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -51,13 +52,13 @@ import static org.junit.jupiter.api.Assertions.assertFalse; import static org.junit.jupiter.api.Assertions.fail; /* - This test is slow and flaky. It tends to fail on systems with limited resources and slow I/O. Therefore, it is - disabled by default. Also, suffers from bugs in the couchbase test container: + This test is slow and potentially flaky. It might fail on systems with limited resources and slow I/O. + Most probably due to this bug in the couchbase test container: - https://github.com/testcontainers/testcontainers-java/issues/2993 - Therefore, this test is marked as flaky and only runs if specifically enabled. + Therefore, it is marked as slow test and must be explicitly enabled to be run. */ -//@EnabledIfSystemProperty(named = "enable.flaky.tests", matches = "true") +@EnabledIfSystemProperty(named = "enable.slow.tests", matches = "true") @TestInstance(TestInstance.Lifecycle.PER_CLASS) public class CamelSinkCouchbaseITCase extends CamelSinkTestSupport { @RegisterExtension @@ -116,13 +117,8 @@ public class CamelSinkCouchbaseITCase extends CamelSinkTestSupport { topic = getTopicForTest(this); -try { -String startDelay = System.getProperty("couchbase.test.start.delay", "1000"); - -int delay = Integer.parseInt(startDelay); -Thread.sleep(delay); -} catch (InterruptedException e) { -Thread.currentThread().interrupted(); +if (!TestUtils.waitFor(this::isQueryServiceUp)) { +fail("Query Service failed to become ready in 30 seconds."); } } @@ -191,6 +187,19 @@ p
[camel-kafka-connector] 01/03: Updated doc for latest release.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 245ffbdf08bcc1adfd0726d35844b1e08f1994c3 Author: Andrea Tarocchi AuthorDate: Fri Oct 28 14:24:44 2022 +0200 Updated doc for latest release. --- connectors/pom.xml | 2 +- docs/antora.yml| 2 +- parent/pom.xml | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/connectors/pom.xml b/connectors/pom.xml index 7aeb7100a..839b88516 100644 --- a/connectors/pom.xml +++ b/connectors/pom.xml @@ -178,7 +178,7 @@ camel-kafka-connector-docs-maven-plugin ${project.version} -3.18.1 +3.18.2 diff --git a/docs/antora.yml b/docs/antora.yml index 88f22e805..b940a0cc6 100644 --- a/docs/antora.yml +++ b/docs/antora.yml @@ -32,7 +32,7 @@ asciidoc: prerelease: true camel-version: 3.19.0-SNAPSHOT camel-docs-version: next -camel-kamelets-version: 0.9.0 +camel-kamelets-version: 0.9.1 camel-kamelets-docs-version: 0.9.x kafka-version: 2.8.0 kafka-docs-version: 28 diff --git a/parent/pom.xml b/parent/pom.xml index ad829e828..15ffd3f7f 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -29,7 +29,7 @@ 2.8.0 3.19.0 -0.9.0 +0.9.1 1.3.2.Final 4.5.6.Final 11
[camel-website] branch valdar-patch-1 created (now 50195b3a)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git at 50195b3a Create lease-3.18.2.md This branch includes the following new commits: new 50195b3a Create lease-3.18.2.md The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-website] 01/01: Create lease-3.18.2.md
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch valdar-patch-1 in repository https://gitbox.apache.org/repos/asf/camel-website.git commit 50195b3a23e4e2f1e42105d4aeae5ac13906eff1 Author: Andrea Tarocchi AuthorDate: Fri Oct 28 13:24:03 2022 +0200 Create lease-3.18.2.md --- content/releases/ckc/lease-3.18.2.md | 11 +++ 1 file changed, 11 insertions(+) diff --git a/content/releases/ckc/lease-3.18.2.md b/content/releases/ckc/lease-3.18.2.md new file mode 100644 index ..1cba58e1 --- /dev/null +++ b/content/releases/ckc/lease-3.18.2.md @@ -0,0 +1,11 @@ +--- +url: "/releases/ckc-3.18.2/" +date: 2022-10-21 +type: release-note +version: "3.18.2" +title: "Camel Kafka Connector release 3.18.2" +preview: "" +changelog: "" +category: "camel-kafka-connector" +jdk: [8,11] +---
svn commit: r57507 - in /release/camel/camel-kafka-connector/3.18.2: ./ camel-kafka-connector-3.18.2-src.zip camel-kafka-connector-3.18.2-src.zip.asc camel-kafka-connector-3.18.2-src.zip.sha512
Author: valdar Date: Fri Oct 21 20:06:50 2022 New Revision: 57507 Log: Camel Kafka Connector 3.18.2 import. Added: release/camel/camel-kafka-connector/3.18.2/ release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip (with props) release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip.asc (with props) release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip.sha512 Added: release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip.sha512 == --- release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/3.18.2/camel-kafka-connector-3.18.2-src.zip.sha512 Fri Oct 21 20:06:50 2022 @@ -0,0 +1 @@ +d829dccc9b048d0406d10ffacdbe305d8201b714b495e42f3cf6a009e3ccab37d24b9dace37520c090b9bbe9bf01a466d53cc916661cf3f1dc3302fe4558 \ No newline at end of file
[camel-kafka-connector] tag camel-kafka-connector-3.18.2 updated (0fb5d2df5 -> 306d35528)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-3.18.2 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git *** WARNING: tag camel-kafka-connector-3.18.2 was modified! *** from 0fb5d2df5 (tag) to 306d35528 (commit) from 654f669ce [maven-release-plugin] prepare release camel-kafka-connector-3.18.2 new 306d35528 [after release perform chore]: regen catalog descriptors with new version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../generated/resources/connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-streams-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-eventbridge-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-kinesis-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-kinesis-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-lambda-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-redshift-sink-sink.json| 2 +- .../resources/connectors/camel-aws-redshift-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-s3-source-source.json | 2 +- .../resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ses-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-fifo-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-sns-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-fifo-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws-sqs-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sqs-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../resources/connectors/camel-azure-cosmosdb-source-source.json| 2 +- .../generated/resources/connectors/camel-azure-eventhubs-sink-sink.json | 2 +- .../resources/connectors/camel-azure-eventhubs-source-source.json | 2 +- .../generated/resources/connectors/camel-azure-functions-sink-sink.json | 2 +- .../resources/connectors/camel-azure-servicebus-sink-sink.json | 2 +- .../resources/connectors/camel-azure-servicebus-source-source.json | 2 +- .../connectors/camel-azure-storage-blob-changefeed-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-blob-sink-sink.json| 2 +- .../resources/connectors/camel-azure-storage-blob-source-source.json| 2 +- .../resources/connectors/camel-azure-storage-queue-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-queue-source-source.json | 2 +- .../src/generated/resources/connectors/camel-beer-source-source.json| 2 +- .../src/generated/resources/connectors/camel-bitcoin-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cassandra-sink-sink.json | 2 +- .../generated/resources/connectors/camel-cassandra-source-source.json | 2 +- .../src/generated/resources/connectors/camel-ceph-sink-sink.json| 2 +- .../src/generated/resources/connectors/camel-ceph-source-source.json| 2 +- .../resources/connectors/camel-chuck-norris-source-source.json | 2 +- .../src/generated/resources/connectors/camel-couchbase-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-cron-source-source.json| 2 +- .../src/generated/resources/connectors/camel-cxf-sink.json | 2 +- .../src/generated/resources/connectors/camel-cxf-source.json| 2 +- .../src/generated/resources/connectors/camel-cxfrs-sink.json| 2 +- .../src/generated/resources/connectors/camel-cxfrs-source.json | 2 +- .../src/generated/resources/connectors/camel-dropbox-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-dropbox-source-source.json | 2 +- .../generated/resources/connectors/camel-earthquake-source-source.json | 2 +- .../resources/connectors/camel-elasticsearch-index-sink-sink.json | 2 +- .../resources/connectors/camel-elasticsearch-search-sou
[camel-kafka-connector] branch camel-kafka-connector-3.18.x updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-3.18.x by this push: new cfdb48a24 [maven-release-plugin] prepare for next development iteration cfdb48a24 is described below commit cfdb48a24d30b2fe47906580787f02597e88f7d6 Author: Andrea Tarocchi AuthorDate: Tue Oct 18 14:56:19 2022 +0200 [maven-release-plugin] prepare for next development iteration --- .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-functions-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-servicebus-sink-kafka-connector/pom.xml| 2 +- connectors/camel-azure-servicebus-source-kafka-connector/pom.xml | 2 +- .../pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-beer-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-ceph-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ceph-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml| 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml | 2 +- connectors/camel-earthquake-source-kafka-connector/pom.xml| 2 +- connectors/camel-elasticsearch-index-sink-kafka-connector/pom.xml | 2 +- connectors/camel
[camel-kafka-connector] branch camel-kafka-connector-3.18.x updated: [maven-release-plugin] prepare release camel-kafka-connector-3.18.2
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-3.18.x by this push: new 654f669ce [maven-release-plugin] prepare release camel-kafka-connector-3.18.2 654f669ce is described below commit 654f669ceb6df4b12642757f6932ff0ff9ddd2ba Author: Andrea Tarocchi AuthorDate: Tue Oct 18 14:56:11 2022 +0200 [maven-release-plugin] prepare release camel-kafka-connector-3.18.2 --- .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-functions-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-servicebus-sink-kafka-connector/pom.xml| 2 +- connectors/camel-azure-servicebus-source-kafka-connector/pom.xml | 2 +- .../pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-beer-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-ceph-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ceph-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml| 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml | 2 +- connectors/camel-earthquake-source-kafka-connector/pom.xml| 2 +- connectors/camel-elasticsearch-index-sink-kafka-connector/pom.xml | 2 +- connectors/camel
[camel-kafka-connector] annotated tag camel-kafka-connector-3.18.2 created (now 0fb5d2df5)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-3.18.2 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at 0fb5d2df5 (tag) tagging 654f669ceb6df4b12642757f6932ff0ff9ddd2ba (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Tue Oct 18 14:56:15 2022 +0200 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-3.18.2 --- No new revisions were added by this update.
[camel-kafka-connector] 01/02: Bumped camel version to 3.18.2 and catalog to 0.9.1
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit c52c8719244229cb478d3c603b8599846b70e3e1 Author: Andrea Tarocchi AuthorDate: Tue Oct 18 13:42:26 2022 +0200 Bumped camel version to 3.18.2 and catalog to 0.9.1 --- parent/pom.xml | 4 ++-- pom.xml| 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/parent/pom.xml b/parent/pom.xml index 524af153b..0fa2299d5 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -28,8 +28,8 @@ UTF-8 2.8.0 -3.18.1 -0.9.0 +3.18.2 +0.9.1 1.3.2.Final 4.5.6.Final 11 diff --git a/pom.xml b/pom.xml index 15d246a26..b9f33092c 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,7 @@ org.apache.camel camel-dependencies -3.18.1 +3.18.2 org.apache.camel.kafkaconnector
[camel-kafka-connector] branch camel-kafka-connector-3.18.x updated (9705e8f3c -> e390b1285)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git from 9705e8f3c fix #1447 Unused import removal new c52c87192 Bumped camel version to 3.18.2 and catalog to 0.9.1 new e390b1285 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-aws-s3-streaming-upload-sink-sink.json | 7 --- .../camel-azure-storage-blob-sink-sink.json| 7 +++ .../camel-azure-storage-blob-source-source.json| 7 +++ .../camel-google-bigquery-sink-sink.json | 6 +++--- .../camel-google-storage-source-source.json| 2 +- .../connectors/camel-rabbitmq-source-source.json | 7 +++ .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 4 ++-- .../camel-aws-ddb-sink-kafka-connector/pom.xml | 10 +- .../resources/kamelets/aws-ddb-sink.kamelet.yaml | 6 +++--- .../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 ++-- .../kamelets/aws-kinesis-source.kamelet.yaml | 4 ++-- .../kamelets/aws-lambda-sink.kamelet.yaml | 4 ++-- .../kamelets/aws-redshift-sink.kamelet.yaml| 2 +- .../kamelets/aws-redshift-source.kamelet.yaml | 2 +- .../resources/kamelets/aws-s3-sink.kamelet.yaml| 4 ++-- .../resources/kamelets/aws-s3-source.kamelet.yaml | 4 ++-- .../camel-aws-s3-streaming-upload-sink-sink.json | 7 --- ...wss3streaminguploadsinkSinkConnectorConfig.java | 4 .../aws-s3-streaming-upload-sink.kamelet.yaml | 13 +++-- .../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 ++-- .../resources/kamelets/aws-sqs-source.kamelet.yaml | 4 ++-- .../kamelets/azure-cosmosdb-source.kamelet.yaml| 2 +- .../kamelets/azure-eventhubs-sink.kamelet.yaml | 2 +- .../kamelets/azure-eventhubs-source.kamelet.yaml | 2 +- .../kamelets/azure-functions-sink.kamelet.yaml | 2 +- .../kamelets/azure-servicebus-sink.kamelet.yaml| 2 +- .../kamelets/azure-servicebus-source.kamelet.yaml | 2 +- ...ure-storage-blob-changefeed-source.kamelet.yaml | 2 +- .../camel-azure-storage-blob-sink-sink.json| 7 +++ ...melAzurestorageblobsinkSinkConnectorConfig.java | 4 .../kamelets/azure-storage-blob-sink.kamelet.yaml | 10 -- .../camel-azure-storage-blob-source-source.json| 7 +++ ...zurestorageblobsourceSourceConnectorConfig.java | 4 .../azure-storage-blob-source.kamelet.yaml | 8 +++- .../kamelets/azure-storage-queue-sink.kamelet.yaml | 2 +- .../azure-storage-queue-source.kamelet.yaml| 2 +- .../resources/kamelets/beer-source.kamelet.yaml| 2 +- .../resources/kamelets/bitcoin-source.kamelet.yaml | 2 +- .../resources/kamelets/cassandra-sink.kamelet.yaml | 2 +- .../kamelets/cassandra-source.kamelet.yaml | 2 +- .../main/resources/kamelets/ceph-sink.kamelet.yaml | 2 +- .../resources/kamelets/ceph-source.kamelet.yaml| 2 +- .../kamelets/chuck-norris-source.kamelet.yaml | 6 +++--- .../resources/kamelets/couchbase-sink.kamelet.yaml | 2 +- .../resources/kamelets/cron-source.kamelet.yaml| 2 +- .../resources/kamelets/dropbox-sink.kamelet.yaml | 2 +- .../resources/kamelets/dropbox-source.kamelet.yaml | 2 +- .../kamelets/earthquake-source.kamelet.yaml| 2 +- .../kamelets/elasticsearch-index-sink.kamelet.yaml | 2 +- .../elasticsearch-search-source.kamelet.yaml | 7 --- .../main/resources/kamelets/exec-sink.kamelet.yaml | 2 +- .../resources/kamelets/fhir-source.kamelet.yaml| 2 +- .../kamelets/file-watch-source.kamelet.yaml| 2 +- .../main/resources/kamelets/ftp-sink.kamelet.yaml | 2 +- .../resources/kamelets/ftp-source.kamelet.yaml | 2 +- .../main/resources/kamelets/ftps-sink.kamelet.yaml | 2 +- .../resources/kamelets/ftps-source.kamelet.yaml| 2 +- .../kamelets/github-commit-source.kamelet.yaml | 2 +- .../kamelets/github-event-source.kamelet.yaml | 2 +- .../github-pullrequest-comment-source.kamelet.yaml | 2 +- .../github-pullrequest
[camel-kafka-connector] 02/02: fix #1447 Unused import removal
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 9705e8f3c95dd1ec5511957b1a267de629e67ce9 Author: Jakub Malek AuthorDate: Wed Oct 12 12:41:30 2022 +0200 fix #1447 Unused import removal --- .../src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java | 1 - 1 file changed, 1 deletion(-) diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java index 598d7a3d2..eafcd45e1 100644 --- a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java +++ b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java @@ -34,7 +34,6 @@ import org.apache.kafka.connect.data.SchemaAndValue; import org.apache.kafka.connect.data.SchemaBuilder; import org.apache.kafka.connect.errors.ConnectException; import org.apache.kafka.connect.sink.SinkRecord; -import org.apache.kafka.connect.sink.SinkTask; import org.apache.kafka.connect.storage.SimpleHeaderConverter; import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach;
[camel-kafka-connector] 01/02: fix #1447 Fixed NPE error during SinkTask header mapping
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit c07d4380ca9c684e6c44cecbffaa99acaab8f377 Author: Jakub Malek AuthorDate: Wed Oct 12 12:32:36 2022 +0200 fix #1447 Fixed NPE error during SinkTask header mapping --- .../apache/camel/kafkaconnector/CamelSinkTask.java | 3 +- .../camel/kafkaconnector/CamelSinkTaskTest.java| 188 - 2 files changed, 77 insertions(+), 114 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java index a53f298c5..b66bce262 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java @@ -240,7 +240,8 @@ public class CamelSinkTask extends SinkTask { final String key = StringHelper.after(header.key(), prefix, header.key()); final Schema schema = header.schema(); -if (schema.type().equals(Schema.BYTES_SCHEMA.type()) +if (schema != null +&& schema.type().equals(Schema.BYTES_SCHEMA.type()) && Objects.equals(schema.name(), Decimal.LOGICAL_NAME) && header.value() instanceof byte[]) { destination.put(key, Decimal.toLogical(schema, (byte[]) header.value())); diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java index c08a4f74c..598d7a3d2 100644 --- a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java +++ b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java @@ -19,6 +19,7 @@ package org.apache.camel.kafkaconnector; import java.math.BigDecimal; import java.util.ArrayList; +import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.List; @@ -33,7 +34,10 @@ import org.apache.kafka.connect.data.SchemaAndValue; import org.apache.kafka.connect.data.SchemaBuilder; import org.apache.kafka.connect.errors.ConnectException; import org.apache.kafka.connect.sink.SinkRecord; +import org.apache.kafka.connect.sink.SinkTask; import org.apache.kafka.connect.storage.SimpleHeaderConverter; +import org.junit.jupiter.api.AfterEach; +import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; @@ -43,20 +47,32 @@ import static org.junit.jupiter.api.Assertions.assertNull; import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertTrue; -public class CamelSinkTaskTest { +class CamelSinkTaskTest { private static final String SEDA_URI = "seda:test"; private static final String TOPIC_NAME = "my-topic"; private static final long RECEIVE_TIMEOUT = 1_000; private static final String TOPIC_CONF = "topics"; +private CamelSinkTask sinkTask; + +@BeforeEach +void setup() { +sinkTask = new CamelSinkTask(); +} + +@AfterEach +void tearDown() { +sinkTask.stop(); +} + + @Test -public void testOnlyBody() { +void testOnlyBody() { Map props = new HashMap<>(); props.put(TOPIC_CONF, TOPIC_NAME); props.put(CamelSinkConnectorConfig.CAMEL_SINK_URL_CONF, SEDA_URI); -CamelSinkTask sinkTask = new CamelSinkTask(); sinkTask.start(props); List records = new ArrayList(); @@ -70,17 +86,14 @@ public class CamelSinkTaskTest { assertEquals("test", exchange.getMessage().getHeaders().get(CamelSinkTask.KAFKA_RECORD_KEY_HEADER)); assertEquals(LoggingLevel.OFF.toString(), sinkTask.getCamelSinkConnectorConfig(props) .getString(CamelSinkConnectorConfig.CAMEL_SINK_CONTENT_LOG_LEVEL_CONF)); - -sinkTask.stop(); } @Test -public void testTopicsRegex() { +void testTopicsRegex() { Map props = new HashMap<>(); props.put("topics.regex", "topic1*"); props.put(CamelSinkConnectorConfig.CAMEL_SINK_URL_CONF, SEDA_URI); -CamelSinkTask sinkTask = new CamelSinkTask(); sinkTask.start(props); List records = new ArrayList(); @@ -99,17 +112,14 @@ public class CamelSinkTaskTest { Exchange exchange1 = consumer.receive(SEDA_URI, RECEIVE_TIMEOUT); assertEquals("cameltopicregex", exchange1.getMessage().getBody()); assertEquals("test", exchange1.getMessage().getHeaders().get(CamelSinkTask.KAFKA_RECORD_KEY_HEADER)); - -sinkTask.stop(); } @Test -public void testBodyAndHeaders() { +void testBod
[camel-kafka-connector] branch camel-kafka-connector-3.18.x updated (af2c7e28d -> 9705e8f3c)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git from af2c7e28d Regen new c07d4380c fix #1447 Fixed NPE error during SinkTask header mapping new 9705e8f3c fix #1447 Unused import removal 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: .../apache/camel/kafkaconnector/CamelSinkTask.java | 3 +- .../camel/kafkaconnector/CamelSinkTaskTest.java| 187 - 2 files changed, 76 insertions(+), 114 deletions(-)
svn commit: r56897 - in /release/camel/camel-kafka-connector/3.18.1: ./ camel-kafka-connector-3.18.1-src.zip camel-kafka-connector-3.18.1-src.zip.asc camel-kafka-connector-3.18.1-src.zip.sha512
Author: valdar Date: Mon Sep 19 20:47:36 2022 New Revision: 56897 Log: Camel Kafka Connector import. Added: release/camel/camel-kafka-connector/3.18.1/ release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip (with props) release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip.asc (with props) release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip.sha512 Added: release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip.sha512 == --- release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/3.18.1/camel-kafka-connector-3.18.1-src.zip.sha512 Mon Sep 19 20:47:36 2022 @@ -0,0 +1 @@ +309a763ecbeb5ac727e66035d0e1be607d433b27eb6fcd3bb327bdb5993af81969d2925f4db82f274ba48ddfd49f425069bc0e1131c4ba46a9956c563d1fa3cd \ No newline at end of file
[camel-kafka-connector] branch main updated (90ffa5a6b -> 840e08f0f)
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 90ffa5a6b chore: removed staging repo and regen. add 2130768c6 [maven-release-plugin] prepare release camel-kafka-connector-3.18.1 add 840e08f0f [maven-release-plugin] prepare for next development iteration No new revisions were added by this update. Summary of changes: .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-functions-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-servicebus-sink-kafka-connector/pom.xml| 2 +- connectors/camel-azure-servicebus-source-kafka-connector/pom.xml | 2 +- .../pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-beer-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-ceph-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ceph-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml| 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml | 2 +- connectors/camel-earthquake-source-kafka-connector/pom.xml| 2 +- connectors/camel-elasticsearch-index-sink-kafka-connector/pom.xml | 2 +- connectors/camel-elasticsearch-search-source-kafka-connector/pom.xml | 2 +- connectors/camel-exec-sink-kafka-connector/pom.xml| 2
[camel-kafka-connector] tag camel-kafka-connector-3.18.1 updated (a231896fa -> 29a551334)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-3.18.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git *** WARNING: tag camel-kafka-connector-3.18.1 was modified! *** from a231896fa (tag) to 29a551334 (commit) from 2130768c6 [maven-release-plugin] prepare release camel-kafka-connector-3.18.1 new 29a551334 [after release perform chore]: regen catalog descriptors with new version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../resources/connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ddb-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-streams-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws-ec2-sink-sink.json | 2 +- .../resources/connectors/camel-aws-eventbridge-sink-sink.json | 4 ++-- .../resources/connectors/camel-aws-kinesis-firehose-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-kinesis-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-source-source.json | 2 +- .../generated/resources/connectors/camel-aws-lambda-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-redshift-sink-sink.json | 2 +- .../resources/connectors/camel-aws-redshift-source-source.json| 2 +- .../src/generated/resources/connectors/camel-aws-s3-sink-sink.json| 2 +- .../generated/resources/connectors/camel-aws-s3-source-source.json| 2 +- .../resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-ses-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sns-fifo-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sns-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-fifo-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sqs-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../resources/connectors/camel-azure-cosmosdb-source-source.json | 2 +- .../resources/connectors/camel-azure-eventhubs-sink-sink.json | 2 +- .../resources/connectors/camel-azure-eventhubs-source-source.json | 2 +- .../resources/connectors/camel-azure-functions-sink-sink.json | 4 ++-- .../resources/connectors/camel-azure-servicebus-sink-sink.json| 2 +- .../resources/connectors/camel-azure-servicebus-source-source.json| 2 +- .../connectors/camel-azure-storage-blob-changefeed-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-blob-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-blob-source-source.json | 2 +- .../resources/connectors/camel-azure-storage-queue-sink-sink.json | 2 +- .../resources/connectors/camel-azure-storage-queue-source-source.json | 2 +- .../src/generated/resources/connectors/camel-beer-source-source.json | 4 ++-- .../generated/resources/connectors/camel-bitcoin-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cassandra-sink-sink.json | 2 +- .../generated/resources/connectors/camel-cassandra-source-source.json | 2 +- .../src/generated/resources/connectors/camel-ceph-sink-sink.json | 4 ++-- .../src/generated/resources/connectors/camel-ceph-source-source.json | 4 ++-- .../resources/connectors/camel-chuck-norris-source-source.json| 2 +- .../src/generated/resources/connectors/camel-couchbase-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-cron-source-source.json | 2 +- .../src/generated/resources/connectors/camel-cxf-sink.json| 2 +- .../src/generated/resources/connectors/camel-cxf-source.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-sink.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-source.json| 2 +- .../src/generated/resources/connectors/camel-dropbox-sink-sink.json | 2 +- .../generated/resources/connectors/camel-dropbox-source-source.json | 2 +- .../resources/connectors/camel-earthquake-source-source.json | 2 +- .../resources/connectors/camel-elasticsearch-index-sink-sink.json | 2 +- .../connectors/camel-elasticsearch-search-source-source.json | 2 +- .../src/generated/resources/connectors/camel-exec-sink-sink.json
[camel-kafka-connector] branch camel-kafka-connector-3.18.x updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-3.18.x by this push: new 840e08f0f [maven-release-plugin] prepare for next development iteration 840e08f0f is described below commit 840e08f0f41d87ef6a3329253a40fac837f50fc9 Author: Andrea Tarocchi AuthorDate: Mon Sep 12 17:33:00 2022 +0200 [maven-release-plugin] prepare for next development iteration --- .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-functions-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-servicebus-sink-kafka-connector/pom.xml| 2 +- connectors/camel-azure-servicebus-source-kafka-connector/pom.xml | 2 +- .../pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-beer-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-ceph-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ceph-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml| 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml | 2 +- connectors/camel-earthquake-source-kafka-connector/pom.xml| 2 +- connectors/camel-elasticsearch-index-sink-kafka-connector/pom.xml | 2 +- connectors/camel
[camel-kafka-connector] 01/01: [maven-release-plugin] prepare release camel-kafka-connector-3.18.1
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 2130768c64be6a73f05c4a523a3a64f383640e42 Author: Andrea Tarocchi AuthorDate: Mon Sep 12 17:32:51 2022 +0200 [maven-release-plugin] prepare release camel-kafka-connector-3.18.1 --- .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-functions-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-servicebus-sink-kafka-connector/pom.xml| 2 +- connectors/camel-azure-servicebus-source-kafka-connector/pom.xml | 2 +- .../pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-beer-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-ceph-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ceph-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml| 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml | 2 +- connectors/camel-earthquake-source-kafka-connector/pom.xml| 2 +- connectors/camel-elasticsearch-index-sink-kafka-connector/pom.xml | 2 +- connectors/camel-elasticsearch-search-source-kafka-connector/pom.xml | 2 +- connectors/camel-exec-sink-kafka-connector/pom.xml| 2 +- connectors/camel-fhir-source-kafka-connector/pom.xml
[camel-kafka-connector] annotated tag camel-kafka-connector-3.18.1 created (now a231896fa)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-3.18.1 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at a231896fa (tag) tagging 2130768c64be6a73f05c4a523a3a64f383640e42 (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Mon Sep 12 17:32:56 2022 +0200 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-3.18.1 --- No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-3.18.x created (now 2130768c6)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-3.18.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git at 2130768c6 [maven-release-plugin] prepare release camel-kafka-connector-3.18.1 This branch includes the following new commits: new 2130768c6 [maven-release-plugin] prepare release camel-kafka-connector-3.18.1 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[camel-kafka-connector] branch main updated (362fdcb08 -> 9daa63e7f)
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 362fdcb08 Updated CHANGELOG.md new deedb4c97 Reneabled tests. new 9daa63e7f 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: .../connectors/camel-github-source-source.json | 38 - connectors/camel-syslog-kafka-connector/pom.xml| 36 .../CamelStreamCacheConverterLoader.java | 52 .../services/org/apache/camel/TypeConverterLoader | 2 + .../converters/CamelStreamCacheConverter.java | 38 - connectors/pom.xml | 3 + .../source/CamelSourceAWSKinesisITCase.java| 2 - .../aws/v2/sns/sink/CamelSinkAWSSNSITCase.java | 1 - .../v2/sqs/sink/CamelAWSSQSPropertyFactory.java| 4 +- .../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 2 - .../v2/sqs/source/CamelAWSSQSPropertyFactory.java | 4 +- .../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 2 - tests/itests-cassandra/pom.xml | 8 ++ .../sink/CamelCassandraPropertyFactory.java| 32 +++- .../cassandra/sink/CamelSinkCassandraITCase.java | 28 +++ .../source/CamelCassandraPropertyFactory.java | 28 +++ .../source/CamelSourceCassandraITCase.java | 8 +- tests/itests-couchbase/pom.xml | 2 +- .../sink/CamelCouchbasePropertyFactory.java| 34 +++- .../couchbase/sink/CamelSinkCouchbaseITCase.java | 27 +- .../sink/CamelSinkElasticSearchITCase.java | 5 -- .../common/CkcMongoDBLocalContainerService.java| 95 ++ .../common/MongoDBEnvVarServiceFactory.java| 5 +- .../common/MongoDBLocalContainerEnvVarService.java | 10 ++- .../mongodb/sink/CamelMongoDBPropertyFactory.java | 4 +- .../mongodb/sink/CamelSinkMongoDBITCase.java | 22 ++--- .../source/CamelMongoDBPropertyFactory.java| 4 +- .../mongodb/source/CamelSourceMongoDBITCase.java | 11 +-- tests/itests-parent/pom.xml| 2 +- .../source/CamelRabbitMQPropertyFactory.java | 4 + .../rabbitmq/source/RabbitMQSourceITCase.java | 37 +++-- .../sql/source/CamelSourceSQLITCase.java | 9 +- .../sql/source/CamelSqlPropertyFactory.java| 2 +- .../ssh/sink/CamelSinkSshITCase.java | 4 - .../ssh/sink/CamelSshPropertyFactory.java | 2 +- .../ssh/source/CamelSourceSshITCase.java | 3 - .../syslog/sink/CamelSinkSyslogITCase.java | 2 - 37 files changed, 342 insertions(+), 230 deletions(-) delete mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-github-source-source.json create mode 100644 connectors/camel-syslog-kafka-connector/src/generated/java/org/apache/camel/kafkaconnector/syslog/converters/CamelStreamCacheConverterLoader.java create mode 100644 connectors/camel-syslog-kafka-connector/src/generated/resources/META-INF/services/org/apache/camel/TypeConverterLoader copy core/src/test/java/org/apache/camel/kafkaconnector/test/TestBlockingQueueFactory.java => connectors/camel-syslog-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/syslog/converters/CamelStreamCacheConverter.java (56%) create mode 100644 tests/itests-mongodb/src/test/java/org/apache/camel/kafkaconnector/mongodb/common/CkcMongoDBLocalContainerService.java
[camel-kafka-connector] 02/02: chore: regen
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 9daa63e7ff2529b46b050d759842805f34e3bb4c Author: Andrea Tarocchi AuthorDate: Mon Sep 12 14:20:30 2022 +0200 chore: regen --- .../connectors/camel-github-source-source.json | 38 -- connectors/pom.xml | 3 ++ 2 files changed, 3 insertions(+), 38 deletions(-) diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-github-source-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-github-source-source.json deleted file mode 100644 index d4751f85d..0 --- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-github-source-source.json +++ /dev/null @@ -1,38 +0,0 @@ -{ - "connector": { - "class": "org.apache.camel.kafkaconnector.githubsource.CamelGithubsourceSourceConnector", - "artifactId": "camel-github-source-kafka-connector", - "groupId": "org.apache.camel.kafkaconnector", - "id": "camel-github-source-source", - "type": "source", - "version": "1.1.0-SNAPSHOT", - "description": "Receive events From Github." - }, - "properties": { - "camel.kamelet.github-source.repoName": { - "name": "camel.kamelet.github-source.repoName", - "description": "The Github Repository name", - "priority": "HIGH", - "required": "true" - }, - "camel.kamelet.github-source.repoOwner": { - "name": "camel.kamelet.github-source.repoOwner", - "description": "The repository owner", - "priority": "HIGH", - "required": "true" - }, - "camel.kamelet.github-source.oauthToken": { - "name": "camel.kamelet.github-source.oauthToken", - "description": "Oauth token", - "priority": "HIGH", - "required": "true" - }, - "camel.kamelet.github-source.type": { - "name": "camel.kamelet.github-source.type", - "description": "The type of event to consume. One of event, pullRequest, pullRequestComment or tag", - "defaultValue": "\"event\"", - "priority": "HIGH", - "required": "true" - } - } -} \ No newline at end of file diff --git a/connectors/pom.xml b/connectors/pom.xml index 120c759b9..d91ece195 100644 --- a/connectors/pom.xml +++ b/connectors/pom.xml @@ -164,6 +164,9 @@ src/generated/resources true + + *.json +
[camel-kafka-connector] 01/02: Reneabled tests.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit deedb4c97061ddee4c192a8f6e2165d9a9e7a131 Author: Andrea Tarocchi AuthorDate: Mon Sep 12 08:16:37 2022 +0200 Reneabled tests. --- connectors/camel-syslog-kafka-connector/pom.xml| 36 .../CamelStreamCacheConverterLoader.java | 52 .../services/org/apache/camel/TypeConverterLoader | 2 + .../converters/CamelStreamCacheConverter.java | 25 -- .../source/CamelSourceAWSKinesisITCase.java| 2 - .../aws/v2/sns/sink/CamelSinkAWSSNSITCase.java | 1 - .../v2/sqs/sink/CamelAWSSQSPropertyFactory.java| 4 +- .../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 2 - .../v2/sqs/source/CamelAWSSQSPropertyFactory.java | 4 +- .../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 2 - tests/itests-cassandra/pom.xml | 8 ++ .../sink/CamelCassandraPropertyFactory.java| 32 +++- .../cassandra/sink/CamelSinkCassandraITCase.java | 28 +++ .../source/CamelCassandraPropertyFactory.java | 28 +++ .../source/CamelSourceCassandraITCase.java | 8 +- tests/itests-couchbase/pom.xml | 2 +- .../sink/CamelCouchbasePropertyFactory.java| 34 +++- .../couchbase/sink/CamelSinkCouchbaseITCase.java | 27 +- .../sink/CamelSinkElasticSearchITCase.java | 5 -- .../common/CkcMongoDBLocalContainerService.java| 95 ++ .../common/MongoDBEnvVarServiceFactory.java| 5 +- .../common/MongoDBLocalContainerEnvVarService.java | 10 ++- .../mongodb/sink/CamelMongoDBPropertyFactory.java | 4 +- .../mongodb/sink/CamelSinkMongoDBITCase.java | 22 ++--- .../source/CamelMongoDBPropertyFactory.java| 4 +- .../mongodb/source/CamelSourceMongoDBITCase.java | 11 +-- tests/itests-parent/pom.xml| 2 +- .../source/CamelRabbitMQPropertyFactory.java | 4 + .../rabbitmq/source/RabbitMQSourceITCase.java | 37 +++-- .../sql/source/CamelSourceSQLITCase.java | 9 +- .../sql/source/CamelSqlPropertyFactory.java| 2 +- .../ssh/sink/CamelSinkSshITCase.java | 4 - .../ssh/sink/CamelSshPropertyFactory.java | 2 +- .../ssh/source/CamelSourceSshITCase.java | 3 - .../syslog/sink/CamelSinkSyslogITCase.java | 2 - 35 files changed, 343 insertions(+), 175 deletions(-) diff --git a/connectors/camel-syslog-kafka-connector/pom.xml b/connectors/camel-syslog-kafka-connector/pom.xml index 46e0c7f78..c9967330d 100644 --- a/connectors/camel-syslog-kafka-connector/pom.xml +++ b/connectors/camel-syslog-kafka-connector/pom.xml @@ -89,6 +89,42 @@ 1.8 + +org.apache.camel +camel-component-maven-plugin + + +generate + + generate + +process-classes + + + + +org.codehaus.mojo +build-helper-maven-plugin + + +initialize + + add-source + add-resource + + + +src/generated/java + + + + src/generated/resources + + + + + + maven-assembly-plugin 2.5.3 diff --git a/connectors/camel-syslog-kafka-connector/src/generated/java/org/apache/camel/kafkaconnector/syslog/converters/CamelStreamCacheConverterLoader.java b/connectors/camel-syslog-kafka-connector/src/generated/java/org/apache/camel/kafkaconnector/syslog/converters/CamelStreamCacheConverterLoader.java new file mode 100644 index 0..2fdcd612e --- /dev/null +++ b/connectors/camel-syslog-kafka-connector/src/generated/java/org/apache/camel/kafkaconnector/syslog/converters/CamelStreamCacheConverterLoader.java @@ -0,0 +1,52 @@ +/* Generated by camel build tools - do NOT edit this file! */ +package org.apache.camel.kafkaconnector.syslog.converters; + +import org.apache.camel.CamelContext; +import org.apache.camel.CamelContextAware; +import org.apache.camel.DeferredContextBinding; +import org.apache.camel.Exchange; +import org.apache.camel.TypeConversionException; +import org.apache.camel.TypeConverterLoaderException; +import org.apache.camel.spi.TypeConverterLoader; +import org.apache.camel.spi.TypeConverterRegistry; +import org.apache.camel.support.SimpleTypeConverter; +import org.apache.camel.support.TypeConverterSupport; +import org.apache.camel.util.DoubleMap; + +/** + * Generated by camel build tools - do NOT edit this file! + */ +@SuppressWarnings("unchecked") +@DeferredContextBinding +public final class CamelStreamCacheConverterLoader implements TypeConverterLoader, CamelCo
[camel-kafka-connector] 01/03: fix #1360 Upgrade to Camel-Kamelets 0.8.0 and Camel 3.16.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 9c0b71f93b4fe2b46e2f4e16244c0c413f7c591c Author: Andrea Tarocchi AuthorDate: Mon May 2 12:16:07 2022 +0200 fix #1360 Upgrade to Camel-Kamelets 0.8.0 and Camel 3.16. --- core/pom.xml | 4 .../transforms/SourcePojoToSchemaAndStructTransform.java | 12 +--- .../camel/kafkaconnector/utils/CamelKafkaConnectMain.java| 4 ++-- parent/pom.xml | 6 +++--- pom.xml | 2 +- .../aws/v2/kinesis/source/CamelSourceAWSKinesisITCase.java | 2 ++ tests/itests-parent/pom.xml | 4 .../camel/kafkaconnector/maven/model/KameletModel.java | 9 +++-- 8 files changed, 24 insertions(+), 19 deletions(-) diff --git a/core/pom.xml b/core/pom.xml index 27525eb8c..817d6a641 100644 --- a/core/pom.xml +++ b/core/pom.xml @@ -59,6 +59,10 @@ org.apache.camel camel-core-languages + +org.apache.camel +camel-bean + org.apache.camel camel-kafka diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java index a8651f2d7..9c47b4659 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java @@ -22,7 +22,6 @@ import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.function.Function; -import com.fasterxml.jackson.databind.JsonMappingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectWriter; import com.fasterxml.jackson.dataformat.avro.AvroFactory; @@ -64,14 +63,13 @@ public class SourcePojoToSchemaAndStructTransform> im try { MAPPER.acceptJsonFormatVisitor(r.value().getClass(), gen); -} catch (JsonMappingException e) { +AvroSchema schemaWrapper = gen.getGeneratedSchema(); +LOG.debug("Generated and cached avro schema: {}", schemaWrapper.getAvroSchema().toString(true)); + +return new CacheEntry(schemaWrapper, MAPPER.writer(schemaWrapper)); +} catch (Exception e) { throw new ConnectException("Error in generating POJO schema.", e); } - -AvroSchema schemaWrapper = gen.getGeneratedSchema(); -LOG.debug("Generated and cached avro schema: {}", schemaWrapper.getAvroSchema().toString(true)); - -return new CacheEntry(schemaWrapper, MAPPER.writer(schemaWrapper)); } }); diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java index 2e8d3a857..e6dba38cb 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelKafkaConnectMain.java @@ -323,7 +323,7 @@ public class CamelKafkaConnectMain extends SimpleMain { .templateParameter("aggregationTimeout", String.valueOf(Long.MAX_VALUE)) .from("kamelet:source") .aggregate(constant(true)) - .aggregationStrategyRef("{{aggregationStrategy}}") +.aggregationStrategy("{{aggregationStrategy}}") .completionSize("{{aggregationSize}}") .completionTimeout("{{aggregationTimeout}}") .to("kamelet:sink") @@ -334,7 +334,7 @@ public class CamelKafkaConnectMain extends SimpleMain { .templateParameter("idempotentExpression", "dummyExpression") .templateParameter("idempotentRepository", "ckcIdempotentRepository") .from("kamelet:source") - .idempotentConsumer(simple("{{idempotentExpression}}")).messageIdRepositoryRef("{{idempotentRepository}}") + .idempotentConsumer(simple("{{idemp
[camel-kafka-connector] 03/03: Updated java version in github actions.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 70ac450d5546d41573d6c21a8f399fd1faadfcf4 Author: Andrea Tarocchi AuthorDate: Tue May 3 10:48:31 2022 +0200 Updated java version in github actions. --- .github/workflows/asf-snapshots-deploy.yml | 2 +- .github/workflows/ci-build.yml | 2 +- .github/workflows/maven-it.yaml| 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/.github/workflows/asf-snapshots-deploy.yml b/.github/workflows/asf-snapshots-deploy.yml index 1dec2c8d6..2b4d49c89 100644 --- a/.github/workflows/asf-snapshots-deploy.yml +++ b/.github/workflows/asf-snapshots-deploy.yml @@ -30,7 +30,7 @@ jobs: runs-on: ubuntu-latest strategy: matrix: -java: [ '8' ] +java: [ '11' ] steps: - uses: actions/checkout@v2.4.0 - name: Set up JDK ${{ matrix.java }} diff --git a/.github/workflows/ci-build.yml b/.github/workflows/ci-build.yml index ec7f5a8cf..d87ce5090 100644 --- a/.github/workflows/ci-build.yml +++ b/.github/workflows/ci-build.yml @@ -32,7 +32,7 @@ jobs: runs-on: ubuntu-latest strategy: matrix: -java: [ '8', '11', '14' ] +java: [ '11', '14' ] steps: - uses: actions/checkout@v1 - name: Set up JDK ${{ matrix.java }} diff --git a/.github/workflows/maven-it.yaml b/.github/workflows/maven-it.yaml index 62c99daa5..cbf04bab1 100644 --- a/.github/workflows/maven-it.yaml +++ b/.github/workflows/maven-it.yaml @@ -30,7 +30,7 @@ jobs: runs-on: ubuntu-latest strategy: matrix: -java: [ '8', '11', '14' ] +java: [ '11', '14' ] steps: - uses: actions/checkout@v1 - name: Set up JDK ${{ matrix.java }}
[camel-kafka-connector] branch main updated (a1fe22c38 -> 70ac450d5)
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 a1fe22c38 Updated CHANGELOG.md new 9c0b71f93 fix #1360 Upgrade to Camel-Kamelets 0.8.0 and Camel 3.16. new 2f98db207 chore: regen after kamelet catalog update. new 70ac450d5 Updated java version in github actions. The 3 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .github/workflows/asf-snapshots-deploy.yml | 2 +- .github/workflows/ci-build.yml | 2 +- .github/workflows/maven-it.yaml| 2 +- .../connectors/camel-aws-cloudwatch-sink-sink.json | 30 +++- .../connectors/camel-aws-ddb-sink-sink.json| 71 + .../camel-aws-ddb-streams-source-source.json | 30 +++- .../connectors/camel-aws-ec2-sink-sink.json| 30 +++- .../camel-aws-kinesis-firehose-sink-sink.json | 30 +++- .../connectors/camel-aws-kinesis-sink-sink.json| 30 +++- .../camel-aws-kinesis-source-source.json | 30 +++- .../connectors/camel-aws-lambda-sink-sink.json | 17 +- .../connectors/camel-aws-s3-sink-sink.json | 36 - .../connectors/camel-aws-s3-source-source.json | 30 +++- .../camel-aws-s3-streaming-upload-sink-sink.json | 30 +++- .../camel-aws-secrets-manager-sink-sink.json | 17 +- .../connectors/camel-aws-ses-sink-sink.json| 44 + .../connectors/camel-aws-sns-fifo-sink-sink.json | 30 +++- .../connectors/camel-aws-sns-sink-sink.json| 30 +++- .../connectors/camel-aws-sqs-batch-sink-sink.json | 31 +++- .../connectors/camel-aws-sqs-fifo-sink-sink.json | 31 +++- .../connectors/camel-aws-sqs-sink-sink.json| 31 +++- .../connectors/camel-aws-sqs-source-source.json| 37 - .../camel-azure-servicebus-sink-sink.json | 25 +++ .../camel-azure-servicebus-source-source.json | 38 + ...zure-storage-blob-changefeed-source-source.json | 32 .../connectors/camel-cassandra-sink-sink.json | 4 +- .../connectors/camel-cassandra-source-source.json | 2 +- .../resources/connectors/camel-file-sink.json | 2 +- .../resources/connectors/camel-file-source.json| 6 - .../camel-github-commit-source-source.json | 44 + .../camel-github-event-source-source.json | 31 ...l-github-pullrequest-comment-source-source.json | 31 .../camel-github-pullrequest-source-source.json| 31 .../connectors/camel-github-tag-source-source.json | 31 .../camel-google-bigquery-sink-sink.json | 37 + .../camel-google-sheets-source-source.json | 10 +- .../camel-jms-apache-activemq-sink-sink.json | 46 ++ .../camel-jms-apache-activemq-source-source.json | 46 ++ .../connectors/camel-kafka-source-source.json | 7 + .../connectors/camel-kafka-ssl-sink-sink.json | 77 + .../connectors/camel-kafka-ssl-source-source.json | 118 ++ .../connectors/camel-mqtt5-sink-sink.json | 37 + .../connectors/camel-mqtt5-source-source.json | 44 + .../connectors/camel-netty-http-sink.json | 28 ++-- .../resources/connectors/camel-netty-sink.json | 28 ++-- .../camel-oracle-database-sink-sink.json | 50 ++ .../camel-oracle-database-source-source.json | 56 +++ .../connectors/camel-rest-openapi-sink-sink.json | 25 +++ .../camel-salesforce-create-sink-sink.json | 50 ++ .../camel-salesforce-delete-sink-sink.json | 44 + .../camel-salesforce-update-sink-sink.json | 56 +++ .../connectors/camel-slack-source-source.json | 8 +- .../resources/descriptors/connectors.properties| 24 ++- .../pom.xml| 4 + .../resources/camel-aws-cloudwatch-sink-sink.json | 30 +++- .../CamelAwscloudwatchsinkSinkConnector.properties | 5 - .../CamelAwscloudwatchsinkSinkConnectorConfig.java | 16 +- .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 41 - .../pom.xml| 19 +-- .../descriptors/connector-sink.properties | 1 + .../resources/camel-aws-ddb-sink-sink.json | 71 + .../src/main/assembly/package.xml | 0 .../CamelAwsddbsinkSinkConnector.properties} | 9 +- .../awsddbsink/CamelAwsddbsinkSinkConnector.java} | 10 +- .../CamelAwsddbsinkSinkConnectorConfig.java| 80 ++ .../awsddbsink/CamelAwsddbsinkSinkTask.java} | 16 +- .../src/main/resources/META-INF/LICENSE.txt| 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../resour
svn commit: r52809 - in /release/camel/camel-kafka-connector/0.11.5: ./ camel-kafka-connector-0.11.5-src.zip camel-kafka-connector-0.11.5-src.zip.asc camel-kafka-connector-0.11.5-src.zip.sha512
Author: valdar Date: Wed Mar 2 18:04:58 2022 New Revision: 52809 Log: Camel Kafka Connector 0.11.5 import. Added: release/camel/camel-kafka-connector/0.11.5/ release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip (with props) release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip.asc (with props) release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip.sha512 Added: release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip.sha512 == --- release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/0.11.5/camel-kafka-connector-0.11.5-src.zip.sha512 Wed Mar 2 18:04:58 2022 @@ -0,0 +1 @@ +473f6663f55b242b3f2c1b7106349ede8db1d9b4ab89d73bb7e48bb3c3983754d00a89840446b3796328206a49425b4486398256a4773f774f9b70542287d1af \ No newline at end of file
[camel-kafka-connector] tag camel-kafka-connector-0.11.5 updated (77c6f3a -> a2042f2)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-0.11.5 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-0.11.5 was modified! *** from 77c6f3a (tag) to a2042f2 (commit) from e459f10 [maven-release-plugin] prepare release camel-kafka-connector-0.11.5 new a2042f2 [after release perform chore]: regen catalog descriptors with new version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../src/generated/resources/connectors/camel-activemq-sink.json | 2 +- .../src/generated/resources/connectors/camel-activemq-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-ws-sink.json | 2 +- .../src/generated/resources/connectors/camel-ahc-ws-source.json | 2 +- .../src/generated/resources/connectors/camel-ahc-wss-sink.json| 2 +- .../src/generated/resources/connectors/camel-ahc-wss-source.json | 2 +- .../src/generated/resources/connectors/camel-amqp-sink.json | 2 +- .../src/generated/resources/connectors/camel-amqp-source.json | 2 +- .../src/generated/resources/connectors/camel-arangodb-sink.json | 2 +- .../src/generated/resources/connectors/camel-as2-sink.json| 2 +- .../src/generated/resources/connectors/camel-as2-source.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-sink.json | 2 +- .../src/generated/resources/connectors/camel-asterisk-source.json | 2 +- .../src/generated/resources/connectors/camel-atlasmap-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-sink.json | 2 +- .../src/generated/resources/connectors/camel-atmos-source.json| 2 +- .../resources/connectors/camel-atmosphere-websocket-sink.json | 2 +- .../resources/connectors/camel-atmosphere-websocket-source.json | 2 +- .../src/generated/resources/connectors/camel-atom-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-map-source.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-sink.json | 2 +- .../generated/resources/connectors/camel-atomix-messaging-source.json | 2 +- .../generated/resources/connectors/camel-atomix-multimap-sink.json| 2 +- .../src/generated/resources/connectors/camel-atomix-queue-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-queue-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-set-source.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-sink.json | 2 +- .../src/generated/resources/connectors/camel-atomix-value-source.json | 2 +- .../src/generated/resources/connectors/camel-avro-sink.json | 2 +- .../src/generated/resources/connectors/camel-avro-source.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-athena-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-cw-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-ddb-sink.json | 2 +- .../generated/resources/connectors/camel-aws2-ddbstream-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ec2-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ecs-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-eks-sink.json | 2 +- .../generated/resources/connectors/camel-aws2-eventbridge-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 2 +- .../resources/connectors/camel-aws2-kinesis-firehose-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-kinesis-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kinesis-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-lambda-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-mq-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-msk-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-s3-sink.json| 2 +- .../src/generated/resources/connectors/camel-aws2-s3-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-ses-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws2-sns-sink.json | 2 +- .../src
[camel-kafka-connector] 01/02: Removed possible port clash in tests.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.11.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 0fc701c315cdffeb7c404a5609d5b80a458f7d7b Author: Andrea Tarocchi AuthorDate: Wed Feb 23 12:27:48 2022 +0100 Removed possible port clash in tests. --- .../apache/camel/kafkaconnector/cxf/source/CamelSourceCXFITCase.java| 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/source/CamelSourceCXFITCase.java b/tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/source/CamelSourceCXFITCase.java index d9dfb6f..eec6d88 100644 --- a/tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/source/CamelSourceCXFITCase.java +++ b/tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/source/CamelSourceCXFITCase.java @@ -40,7 +40,7 @@ import static org.junit.jupiter.api.Assertions.fail; */ public class CamelSourceCXFITCase extends CamelSourceTestSupport { -protected static final int PORT = NetworkUtils.getFreePort("localhost"); +protected static final int PORT = NetworkUtils.getFreePort("localhost", NetworkUtils.DEFAULT_STARTING_PORT - 200, NetworkUtils.DEFAULT_STARTING_PORT - 100); protected static final String SIMPLE_ENDPOINT_ADDRESS = "http://localhost:; + PORT + "/CxfConsumerTest/test"; protected static final String SIMPLE_ENDPOINT_URI = SIMPLE_ENDPOINT_ADDRESS + "?serviceClass=org.apache.camel.kafkaconnector.cxf.common.HelloService"
[camel-kafka-connector] annotated tag camel-kafka-connector-0.11.5 created (now 77c6f3a)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-0.11.5 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 77c6f3a (tag) tagging e459f10a74c251e3c5a9b1636861131beda56b2e (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Wed Feb 23 16:03:35 2022 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-0.11.5 --- No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-0.11.x updated (8f80903 -> e459f10)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.11.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from 8f80903 fix: regenerate nav.adoc and index.adoc new 0fc701c Removed possible port clash in tests. new e459f10 [maven-release-plugin] prepare release camel-kafka-connector-0.11.5 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-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-activemq-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-ws-kafka-connector/pom.xml | 2 +- connectors/camel-ahc-wss-kafka-connector/pom.xml | 2 +- connectors/camel-amqp-kafka-connector/pom.xml | 2 +- connectors/camel-arangodb-kafka-connector/pom.xml | 2 +- connectors/camel-as2-kafka-connector/pom.xml | 2 +- connectors/camel-asterisk-kafka-connector/pom.xml | 2 +- connectors/camel-atlasmap-kafka-connector/pom.xml | 2 +- connectors/camel-atmos-kafka-connector/pom.xml| 2 +- connectors/camel-atmosphere-websocket-kafka-connector/pom.xml | 2 +- connectors/camel-atom-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-map-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-messaging-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-multimap-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-queue-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-set-kafka-connector/pom.xml | 2 +- connectors/camel-atomix-value-kafka-connector/pom.xml | 2 +- connectors/camel-avro-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-athena-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-cw-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ddb-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ddbstream-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ec2-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ecs-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-eks-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-eventbridge-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kinesis-firehose-kafka-connector/pom.xml| 2 +- connectors/camel-aws2-kinesis-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-lambda-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-mq-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-msk-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-s3-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-ses-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-sns-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-sqs-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-sts-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-translate-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-datalake-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-kafka-connector/pom.xml | 2 +- connectors/camel-bean-kafka-connector/pom.xml | 2 +- connectors/camel-beanstalk-kafka-connector/pom.xml| 2 +- connectors/camel-box-kafka-connector/pom.xml | 2 +- connectors/camel-brain
[camel-kafka-connector] branch camel-kafka-connector-0.11.x updated (c7f2729 -> b47e586)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-0.11.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from c7f2729 global util functions for compatibility table refs new 00ee35f fix #1332 : CameHeader value is wrongly interpreted as BigDecimal and causes ClassCastException. new b47e586 Update to camel 3.11.5 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: .../resources/connectors/camel-github-source.json | 14 +- .../connectors/camel-google-pubsub-sink.json | 32 --- .../connectors/camel-google-pubsub-source.json | 38 ++-- .../resources/connectors/camel-influxdb-sink.json | 14 ++ .../resources/connectors/camel-mina-sink.json | 18 +- .../resources/connectors/camel-mina-source.json| 32 +-- .../connectors/camel-salesforce-sink.json | 14 ++ .../connectors/camel-salesforce-source.json| 14 ++ .../resources/connectors/camel-sjms2-source.json | 6 +- .../generated/resources/camel-github-source.json | 14 +- .../github/CamelGithubSourceConnectorConfig.java | 8 +- .../resources/camel-google-pubsub-sink.json| 32 --- .../resources/camel-google-pubsub-source.json | 38 ++-- .../CamelGooglepubsubSinkConnectorConfig.java | 16 -- .../CamelGooglepubsubSourceConnectorConfig.java| 24 +-- .../generated/resources/camel-influxdb-sink.json | 14 ++ .../influxdb/CamelInfluxdbSinkConnectorConfig.java | 8 + .../src/generated/resources/camel-mina-sink.json | 18 +- .../src/generated/resources/camel-mina-source.json | 32 +-- .../mina/CamelMinaSinkConnectorConfig.java | 12 +- .../mina/CamelMinaSourceConnectorConfig.java | 20 +- .../generated/resources/camel-salesforce-sink.json | 14 ++ .../resources/camel-salesforce-source.json | 14 ++ .../CamelSalesforceSinkConnectorConfig.java| 8 + .../CamelSalesforceSourceConnectorConfig.java | 8 + .../generated/resources/camel-sjms2-source.json| 6 +- .../sjms2/CamelSjms2SourceConnectorConfig.java | 6 +- .../apache/camel/kafkaconnector/CamelSinkTask.java | 4 +- .../camel/kafkaconnector/CamelSourceTask.java | 6 +- .../camel/kafkaconnector/CamelSinkTaskTest.java| 14 +- .../camel/kafkaconnector/CamelSourceTaskTest.java | 2 +- docs/modules/ROOT/nav.adoc | 226 + docs/modules/ROOT/pages/reference/index.adoc | 115 ++- parent/pom.xml | 2 +- pom.xml| 2 +- .../maven/CamelKafkaConnectorUpdateMojo.java | 1 - 36 files changed, 630 insertions(+), 216 deletions(-)
[camel-kafka-connector] 01/02: fix #1332 : CameHeader value is wrongly interpreted as BigDecimal and causes ClassCastException.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.11.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 00ee35f7096a809aaa4e09186b8ee5992bbd4ac4 Author: Andrea Tarocchi AuthorDate: Mon Jan 31 13:52:51 2022 +0100 fix #1332 : CameHeader value is wrongly interpreted as BigDecimal and causes ClassCastException. --- .../org/apache/camel/kafkaconnector/CamelSinkTask.java | 4 +++- .../org/apache/camel/kafkaconnector/CamelSourceTask.java | 6 +++--- .../org/apache/camel/kafkaconnector/CamelSinkTaskTest.java | 14 -- .../apache/camel/kafkaconnector/CamelSourceTaskTest.java | 2 +- 4 files changed, 19 insertions(+), 7 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java index 82c16d2..af9b259 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java @@ -229,7 +229,9 @@ public class CamelSinkTask extends SinkTask { final String key = StringHelper.after(header.key(), prefix, header.key()); final Schema schema = header.schema(); -if (schema.type().equals(Schema.BYTES_SCHEMA.type()) && Objects.equals(schema.name(), Decimal.LOGICAL_NAME)) { +if (schema.type().equals(Schema.BYTES_SCHEMA.type()) +&& Objects.equals(schema.name(), Decimal.LOGICAL_NAME) +&& header.value() instanceof byte[]) { destination.put(key, Decimal.toLogical(schema, (byte[]) header.value())); } else { destination.put(key, header.value()); diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java index 00ce145..183e479 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java @@ -36,7 +36,6 @@ import org.apache.camel.kafkaconnector.utils.SchemaHelper; import org.apache.camel.kafkaconnector.utils.TaskHelper; import org.apache.camel.support.UnitOfWorkHelper; import org.apache.kafka.clients.producer.RecordMetadata; -import org.apache.kafka.connect.data.Decimal; import org.apache.kafka.connect.data.Schema; import org.apache.kafka.connect.errors.ConnectException; import org.apache.kafka.connect.source.SourceRecord; @@ -344,8 +343,9 @@ public class CamelSourceTask extends SourceTask { } else if (value instanceof Date) { record.headers().addTimestamp(keyCamelHeader, (Date)value); } else if (value instanceof BigDecimal) { -Schema schema = Decimal.schema(((BigDecimal)value).scale()); -record.headers().add(keyCamelHeader, Decimal.fromLogical(schema, (BigDecimal)value), schema); +//XXX: kafka connect configured header converter takes care of the encoding, +//default: org.apache.kafka.connect.storage.SimpleHeaderConverter +record.headers().addDecimal(keyCamelHeader, (BigDecimal)value); } else if (value instanceof Double) { record.headers().addDouble(keyCamelHeader, (double)value); } else if (value instanceof Float) { diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java index bab0a5d..c08a4f7 100644 --- a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java +++ b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java @@ -33,6 +33,7 @@ import org.apache.kafka.connect.data.SchemaAndValue; import org.apache.kafka.connect.data.SchemaBuilder; import org.apache.kafka.connect.errors.ConnectException; import org.apache.kafka.connect.sink.SinkRecord; +import org.apache.kafka.connect.storage.SimpleHeaderConverter; import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; @@ -118,7 +119,13 @@ public class CamelSinkTaskTest { int myInteger = 100; Long myLong = new Long("100"); BigDecimal myBigDecimal = new BigDecimal(1234567890); -Schema schema = Decimal.schema(myBigDecimal.scale()); +Schema myBigDecimalSchema = Decimal.schema(myBigDecimal.scale()); +//reproducing bigDecimal encoding by kafka connect +BigDecimal kafkaBigDecimal = new BigDecimal("6.9203120E+787"); +Schema kafkaBigDecimalSchema = Decimal.schema(kafkaBigDecimal.scale()); +SimpleHeaderConverter shc = new SimpleHeaderConverter(); +byte[] persistedBytes = shc.fromConnectHeader("", "MyBigDecimal", kafkaBigDecimalSchema, kafkaBigDecimal); +
[camel-kafka-connector] branch main updated: fix #1332 : CameHeader value is wrongly interpreted as BigDecimal and causes ClassCastException.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new 9323f1e fix #1332 : CameHeader value is wrongly interpreted as BigDecimal and causes ClassCastException. 9323f1e is described below commit 9323f1ece25dd23d557c6b3b12b9c193a6e46f07 Author: Andrea Tarocchi AuthorDate: Mon Jan 31 13:52:51 2022 +0100 fix #1332 : CameHeader value is wrongly interpreted as BigDecimal and causes ClassCastException. --- .../org/apache/camel/kafkaconnector/CamelSinkTask.java | 4 +++- .../org/apache/camel/kafkaconnector/CamelSourceTask.java | 6 +++--- .../org/apache/camel/kafkaconnector/CamelSinkTaskTest.java | 14 -- .../apache/camel/kafkaconnector/CamelSourceTaskTest.java | 2 +- 4 files changed, 19 insertions(+), 7 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java index f5d942e..a53f298 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java @@ -240,7 +240,9 @@ public class CamelSinkTask extends SinkTask { final String key = StringHelper.after(header.key(), prefix, header.key()); final Schema schema = header.schema(); -if (schema.type().equals(Schema.BYTES_SCHEMA.type()) && Objects.equals(schema.name(), Decimal.LOGICAL_NAME)) { +if (schema.type().equals(Schema.BYTES_SCHEMA.type()) +&& Objects.equals(schema.name(), Decimal.LOGICAL_NAME) +&& header.value() instanceof byte[]) { destination.put(key, Decimal.toLogical(schema, (byte[]) header.value())); } else { destination.put(key, header.value()); diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java index 05a0d96..8b993a2 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java @@ -36,7 +36,6 @@ import org.apache.camel.kafkaconnector.utils.SchemaHelper; import org.apache.camel.kafkaconnector.utils.TaskHelper; import org.apache.camel.support.UnitOfWorkHelper; import org.apache.kafka.clients.producer.RecordMetadata; -import org.apache.kafka.connect.data.Decimal; import org.apache.kafka.connect.data.Schema; import org.apache.kafka.connect.errors.ConnectException; import org.apache.kafka.connect.source.SourceRecord; @@ -357,8 +356,9 @@ public class CamelSourceTask extends SourceTask { } else if (value instanceof Date) { record.headers().addTimestamp(keyCamelHeader, (Date)value); } else if (value instanceof BigDecimal) { -Schema schema = Decimal.schema(((BigDecimal)value).scale()); -record.headers().add(keyCamelHeader, Decimal.fromLogical(schema, (BigDecimal)value), schema); +//XXX: kafka connect configured header converter takes care of the encoding, +//default: org.apache.kafka.connect.storage.SimpleHeaderConverter +record.headers().addDecimal(keyCamelHeader, (BigDecimal)value); } else if (value instanceof Double) { record.headers().addDouble(keyCamelHeader, (double)value); } else if (value instanceof Float) { diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java index bab0a5d..c08a4f7 100644 --- a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java +++ b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSinkTaskTest.java @@ -33,6 +33,7 @@ import org.apache.kafka.connect.data.SchemaAndValue; import org.apache.kafka.connect.data.SchemaBuilder; import org.apache.kafka.connect.errors.ConnectException; import org.apache.kafka.connect.sink.SinkRecord; +import org.apache.kafka.connect.storage.SimpleHeaderConverter; import org.junit.jupiter.api.Test; import static org.assertj.core.api.Assertions.assertThat; @@ -118,7 +119,13 @@ public class CamelSinkTaskTest { int myInteger = 100; Long myLong = new Long("100"); BigDecimal myBigDecimal = new BigDecimal(1234567890); -Schema schema = Decimal.schema(myBigDecimal.scale()); +Schema myBigDecimalSchema = Decimal.schema(myBigDecimal.scale()); +//reproducing bigDecimal encoding by kafka connect +BigDecimal kafkaBigDecimal = new BigDecimal("6.9203120E+787"); +Schema kafkaBigDecimalSchema = Decimal.schema(kafkaBigDecimal.scale()); +SimpleHea
[camel-kafka-connector] branch main updated: fix #1301: updated actions/checkout to version v2.4.0
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new fb6ef90 fix #1301: updated actions/checkout to version v2.4.0 fb6ef90 is described below commit fb6ef90dc574bda57e0d3009d51d2b7d0d43f156 Author: Andrea Tarocchi AuthorDate: Thu Jan 27 00:37:05 2022 +0100 fix #1301: updated actions/checkout to version v2.4.0 --- .github/workflows/asf-snapshots-deploy.yml | 4 ++-- .github/workflows/automatic-changelog-update.yml | 2 +- .github/workflows/automatic-sync-camel-main.yml | 4 ++-- .github/workflows/backport.yml | 2 +- .github/workflows/daily-java-next.yml| 2 +- 5 files changed, 7 insertions(+), 7 deletions(-) diff --git a/.github/workflows/asf-snapshots-deploy.yml b/.github/workflows/asf-snapshots-deploy.yml index 42fa055..1dec2c8 100644 --- a/.github/workflows/asf-snapshots-deploy.yml +++ b/.github/workflows/asf-snapshots-deploy.yml @@ -32,7 +32,7 @@ jobs: matrix: java: [ '8' ] steps: - - uses: actions/checkout@v2 + - uses: actions/checkout@v2.4.0 - name: Set up JDK ${{ matrix.java }} uses: AdoptOpenJDK/install-jdk@v1 with: @@ -52,7 +52,7 @@ jobs: NEXUS_DEPLOY_USERNAME: ${{ secrets.NEXUS_USER }} NEXUS_DEPLOY_PASSWORD: ${{ secrets.NEXUS_PW }} steps: -- uses: actions/checkout@v2 +- uses: actions/checkout@v2.4.0 - name: Set up JDK 11 uses: AdoptOpenJDK/install-jdk@v1 with: diff --git a/.github/workflows/automatic-changelog-update.yml b/.github/workflows/automatic-changelog-update.yml index 3468ced..e05e8cf 100644 --- a/.github/workflows/automatic-changelog-update.yml +++ b/.github/workflows/automatic-changelog-update.yml @@ -30,7 +30,7 @@ jobs: if: github.ref == 'refs/heads/main' && github.repository == 'apache/camel-kafka-connector' steps: - name: "Checkout camel-kafka-connector" -uses: actions/checkout@v2 +uses: actions/checkout@v2.4.0 with: persist-credentials: false submodules: recursive diff --git a/.github/workflows/automatic-sync-camel-main.yml b/.github/workflows/automatic-sync-camel-main.yml index fbdb7fe..5e2d395 100644 --- a/.github/workflows/automatic-sync-camel-main.yml +++ b/.github/workflows/automatic-sync-camel-main.yml @@ -34,7 +34,7 @@ jobs: java: [ '11' ] steps: - name: Checkout Camel project -uses: actions/checkout@v2 +uses: actions/checkout@v2.4.0 with: repository: apache/camel ref: main @@ -57,7 +57,7 @@ jobs: clean install working-directory: ${{ github.workspace }}/camel - name: Checkout camel-kafka-connector project -uses: actions/checkout@v2 +uses: actions/checkout@v2.4.0 with: ref: main fetch-depth: 0 diff --git a/.github/workflows/backport.yml b/.github/workflows/backport.yml index e05f41b..548eeae 100644 --- a/.github/workflows/backport.yml +++ b/.github/workflows/backport.yml @@ -28,7 +28,7 @@ jobs: name: Backport steps: - name: "Checkout camel-kafka-connector" -uses: actions/checkout@v2 +uses: actions/checkout@v2.4.0 with: persist-credentials: false submodules: recursive diff --git a/.github/workflows/daily-java-next.yml b/.github/workflows/daily-java-next.yml index ff6e685..d94fefc 100644 --- a/.github/workflows/daily-java-next.yml +++ b/.github/workflows/daily-java-next.yml @@ -33,7 +33,7 @@ jobs: matrix: java: [ '15' ] steps: - - uses: actions/checkout@v1 + - uses: actions/checkout@v2.4.0 - name: Set up JDK ${{ matrix.java }} uses: AdoptOpenJDK/install-jdk@v1 with:
svn commit: r52252 - in /release/camel/camel-kafka-connector/1.0.0: ./ camel-kafka-connector-1.0.0-src.zip camel-kafka-connector-1.0.0-src.zip.asc camel-kafka-connector-1.0.0-src.zip.sha512
Author: valdar Date: Mon Jan 24 22:24:58 2022 New Revision: 52252 Log: Camel Kafka Connector 1.0.0 import. Added: release/camel/camel-kafka-connector/1.0.0/ release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip (with props) release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip.asc (with props) release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip.sha512 Added: release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip -- svn:mime-type = application/zip Added: release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip.asc == Binary file - no diff available. Propchange: release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip.asc -- svn:mime-type = application/pgp-signature Added: release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip.sha512 == --- release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip.sha512 (added) +++ release/camel/camel-kafka-connector/1.0.0/camel-kafka-connector-1.0.0-src.zip.sha512 Mon Jan 24 22:24:58 2022 @@ -0,0 +1 @@ +3017cc02cc89b30b107d64696723f2e4368adf8697fa3e6fa69235849c0fa60fd8dcc7329332558c4fa9cf451eecdda3cc38f8f7acf0fb15efacdd8d73b104d0 \ No newline at end of file
[camel-kafka-connector] branch main updated: RI info
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new 356839b RI info 356839b is described below commit 356839b023f5933753e0afe6619ca962a067ed7d Author: David Jencks AuthorDate: Fri Jan 14 16:48:10 2022 -0800 RI info --- connectors/antora.yml | 16 docs/antora.yml| 28 docs/modules/ROOT/pages/index.adoc | 15 +++ 3 files changed, 59 insertions(+) diff --git a/connectors/antora.yml b/connectors/antora.yml index 92a2a5d..6a30c7c 100644 --- a/connectors/antora.yml +++ b/connectors/antora.yml @@ -1,3 +1,19 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# # A distributed part of the component at /docs/antora.yml diff --git a/docs/antora.yml b/docs/antora.yml index ac68ce2..2e4aad3 100644 --- a/docs/antora.yml +++ b/docs/antora.yml @@ -1,3 +1,22 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +# Another part of this distributed component is at components/antora.yml + name: camel-kafka-connector title: Camel Kafka Connector version: next @@ -6,3 +25,12 @@ display-version: Next (Pre-release) nav: - modules/ROOT/nav.adoc + +asciidoc: + attributes: +prerelease: true +camel-version: 3.14.0 +camel-docs-version: 3.14.x +camel-kamelets-version: 0.6.0 +camel-kamelets-docs-version: 0.6.x +kafka-version: 2.8.0 diff --git a/docs/modules/ROOT/pages/index.adoc b/docs/modules/ROOT/pages/index.adoc index ac665bf..66f46eb 100644 --- a/docs/modules/ROOT/pages/index.adoc +++ b/docs/modules/ROOT/pages/index.adoc @@ -1,6 +1,21 @@ [[WhatIsIt-WhatIsIt]] = Camel Kafka Connector +[NOTE] +-- +This version ({page-component-display-version}) of {page-component-title} depends on: + +* https://kafka.apache.org[Apache Kafka] at version {kafka-version} +* xref:{camel-docs-version}@components::index.adoc[Camel] at version {camel-version} +* xref:{camel-kamelets-docs-version}@camel-kamelets::index.adoc[Camel Kamelets] at version {camel-kamelets-version} + +ifdef::lts[This long term service release will be supported until {lts}.] +ifndef::lts[] +ifdef::prerelease[This is the development version of {page-component-title}. It should not be used in production.] +ifndef::prerelease[This release will not be updated, but rather replaced by a new release.] +endif::[] +-- + Camel Kafka Connector allows you to use all Camel xref:components::index.adoc[components] as http://kafka.apache.org/documentation/#connect[Kafka Connect] connectors. The basic idea is reusing the available Camel components as Kafka sink and source connectors in a simple way.
[camel-kafka-connector] 01/02: Removed unused dependency on camel-k-runtime.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 65e2f3f6046fe63038177d5230c10362cce43142 Author: Andrea Tarocchi AuthorDate: Sat Jan 15 01:10:13 2022 +0100 Removed unused dependency on camel-k-runtime. --- parent/pom.xml | 9 - tests/itests-elasticsearch/pom.xml | 11 --- 2 files changed, 20 deletions(-) diff --git a/parent/pom.xml b/parent/pom.xml index 0a30f5a..1a1d92c 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -30,7 +30,6 @@ 2.8.0 3.14.0 0.6.0 -1.8.0 1.3.2.Final 4.5.6.Final 1.8 @@ -119,14 +118,6 @@ -org.apache.camel.k -camel-k-runtime-bom -${camel.k.runtime.version} -pom -import - - - org.apache.camel.kamelets camel-kamelets-catalog ${camel.kamelet.catalog.version} diff --git a/tests/itests-elasticsearch/pom.xml b/tests/itests-elasticsearch/pom.xml index e015d1d..46f351b 100644 --- a/tests/itests-elasticsearch/pom.xml +++ b/tests/itests-elasticsearch/pom.xml @@ -66,17 +66,6 @@ org.apache.camel camel-jackson - -org.apache.camel.k -camel-k-kamelet-reify - - -org.jboss.slf4j -slf4j-jboss-logmanager - - - - \ No newline at end of file
[camel-kafka-connector] branch main updated (0d9bec3 -> e86375d)
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 0d9bec3 Updated CHANGELOG.md new 65e2f3f Removed unused dependency on camel-k-runtime. new e86375d chore: regen after release cut. 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: .../resources/connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../connectors/camel-aws-ddb-streams-source-source.json | 4 ++-- .../resources/connectors/camel-aws-ec2-sink-sink.json | 2 +- .../connectors/camel-aws-kinesis-firehose-sink-sink.json | 4 ++-- .../resources/connectors/camel-aws-kinesis-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-source-source.json | 4 ++-- .../resources/connectors/camel-aws-lambda-sink-sink.json | 4 ++-- .../resources/connectors/camel-aws-redshift-sink-sink.json| 4 ++-- .../connectors/camel-aws-redshift-source-source.json | 4 ++-- .../resources/connectors/camel-aws-s3-sink-sink.json | 4 ++-- .../resources/connectors/camel-aws-s3-source-source.json | 2 +- .../connectors/camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../connectors/camel-aws-secrets-manager-sink-sink.json | 4 ++-- .../resources/connectors/camel-aws-sns-fifo-sink-sink.json| 2 +- .../resources/connectors/camel-aws-sns-sink-sink.json | 2 +- .../resources/connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../resources/connectors/camel-aws-sqs-fifo-sink-sink.json| 2 +- .../resources/connectors/camel-aws-sqs-sink-sink.json | 2 +- .../resources/connectors/camel-aws-sqs-source-source.json | 2 +- .../generated/resources/connectors/camel-aws2-iam-sink.json | 4 ++-- .../generated/resources/connectors/camel-aws2-kms-sink.json | 4 ++-- .../connectors/camel-azure-cosmosdb-source-source.json| 4 ++-- .../resources/connectors/camel-azure-eventhubs-sink-sink.json | 4 ++-- .../connectors/camel-azure-eventhubs-source-source.json | 4 ++-- .../connectors/camel-azure-storage-blob-sink-sink.json| 4 ++-- .../connectors/camel-azure-storage-blob-source-source.json| 4 ++-- .../connectors/camel-azure-storage-queue-sink-sink.json | 4 ++-- .../connectors/camel-azure-storage-queue-source-source.json | 4 ++-- .../resources/connectors/camel-bitcoin-source-source.json | 4 ++-- .../resources/connectors/camel-cassandra-sink-sink.json | 2 +- .../resources/connectors/camel-cassandra-source-source.json | 2 +- .../connectors/camel-chuck-norris-source-source.json | 2 +- .../resources/connectors/camel-couchbase-sink-sink.json | 4 ++-- .../resources/connectors/camel-cron-source-source.json| 4 ++-- .../src/generated/resources/connectors/camel-cxf-sink.json| 2 +- .../src/generated/resources/connectors/camel-cxf-source.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-sink.json | 2 +- .../generated/resources/connectors/camel-cxfrs-source.json| 2 +- .../resources/connectors/camel-dropbox-sink-sink.json | 4 ++-- .../resources/connectors/camel-dropbox-source-source.json | 4 ++-- .../resources/connectors/camel-earthquake-source-source.json | 4 ++-- .../connectors/camel-elasticsearch-index-sink-sink.json | 2 +- .../connectors/camel-elasticsearch-search-source-source.json | 4 ++-- .../generated/resources/connectors/camel-exec-sink-sink.json | 4 ++-- .../resources/connectors/camel-fhir-source-source.json| 4 ++-- .../src/generated/resources/connectors/camel-file-sink.json | 2 +- .../src/generated/resources/connectors/camel-file-source.json | 2 +- .../resources/connectors/camel-file-watch-source-source.json | 2 +- .../generated/resources/connectors/camel-ftp-sink-sink.json | 2 +- .../resources/connectors/camel-ftp-source-source.json | 2 +- .../generated/resources/connectors/camel-ftps-sink-sink.json | 2 +- .../resources/connectors/camel-ftps-source-source.json| 2 +- .../resources/connectors/camel-github-source-source.json | 4 ++-- .../connectors/camel-google-calendar-source-source.json | 4 ++-- .../connectors/camel-google-functions-sink-sink.json | 4 ++-- .../resources/connectors/camel-google-mail-source-source.json | 4 ++-- .../resources/connectors/camel-google-pubsub-sink-sink.json | 4 ++-- .../connectors/camel-google-pubsub-source-source.json | 4 ++-- .../connectors/camel-google-sheets-source-source.json | 2 +- .../resources/connectors/camel-google-storage-sink-sink.json | 4 ++-- .../connectors/camel-google-storage-source-sou
[camel-kafka-connector] branch camel-kafka-connector-1.0.x created (now b9ad25f)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-1.0.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at b9ad25f Fixed actions due to new inter project dependencies. No new revisions were added by this update.
[camel-kafka-connector] branch main updated (b82264a -> b9ad25f)
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 b82264a Updated CHANGELOG.md add b3ec5a3 Updated dependency to timer connector in camel-kafka-connector-extensible-archetype add 64c8f6d [maven-release-plugin] prepare release camel-kafka-connector-1.0.0 add 06bfd8c [maven-release-plugin] prepare for next development iteration add b9ad25f Fixed actions due to new inter project dependencies. No new revisions were added by this update. Summary of changes: .github/workflows/automatic-sync-camel-main.yml| 1 + .github/workflows/ci-build.yml | 1 + .github/workflows/daily-java-next.yml | 1 + .github/workflows/maven-it.yaml| 7 +++ .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml| 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 4 ++-- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml | 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml | 2 +- .../camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- .../camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml| 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml| 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml| 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml| 2 +- connectors/camel-earthquake-source-kafka-connector/pom.xml | 2 +- connectors/camel-elasticsearch-index-sink-kafka-connector/pom.xml | 2 +- .../camel-elasticsearch-search-source-kafka-connector/pom.xml | 2 +- connectors/camel-exec-sink-kafka-connector/pom.xml | 2 +- connectors/camel-fhir-source-kafka-connector/pom.xml | 2 +- connectors/camel-file-kafka-connector/pom.xml | 2 +- connectors/camel-file-watch-source-kafka-connector/pom.xml | 2 +- connectors/camel-ftp-sink-kafka-connector/pom.xml | 2 +- connectors/camel-ftp-source-kafka-connector/pom.xml| 2 +- connectors/camel-ftps-sink-kafka-connector/pom.xml | 2 +- connectors
[camel-kafka-connector] branch camel-kafka-connector-1.0.x updated (06bfd8c -> b9ad25f)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-1.0.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. from 06bfd8c [maven-release-plugin] prepare for next development iteration add b9ad25f Fixed actions due to new inter project dependencies. No new revisions were added by this update. Summary of changes: .github/workflows/automatic-sync-camel-main.yml | 1 + .github/workflows/ci-build.yml | 1 + .github/workflows/daily-java-next.yml | 1 + .github/workflows/maven-it.yaml | 7 +++ 4 files changed, 10 insertions(+)
[camel-kafka-connector] tag camel-kafka-connector-1.0.0 updated (ca6e41c -> b264973)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to tag camel-kafka-connector-1.0.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. *** WARNING: tag camel-kafka-connector-1.0.0 was modified! *** from ca6e41c (tag) to b264973 (commit) from 64c8f6d [maven-release-plugin] prepare release camel-kafka-connector-1.0.0 new b264973 [after release perform chore]: regen catalog descriptors with new version The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../resources/connectors/camel-aws-cloudwatch-sink-sink.json | 2 +- .../resources/connectors/camel-aws-ddb-streams-source-source.json | 4 ++-- .../src/generated/resources/connectors/camel-aws-ec2-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-firehose-sink-sink.json| 4 ++-- .../generated/resources/connectors/camel-aws-kinesis-sink-sink.json | 2 +- .../resources/connectors/camel-aws-kinesis-source-source.json | 4 ++-- .../generated/resources/connectors/camel-aws-lambda-sink-sink.json| 4 ++-- .../generated/resources/connectors/camel-aws-redshift-sink-sink.json | 4 ++-- .../resources/connectors/camel-aws-redshift-source-source.json| 4 ++-- .../src/generated/resources/connectors/camel-aws-s3-sink-sink.json| 4 ++-- .../generated/resources/connectors/camel-aws-s3-source-source.json| 2 +- .../resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json | 2 +- .../resources/connectors/camel-aws-secrets-manager-sink-sink.json | 4 ++-- .../generated/resources/connectors/camel-aws-sns-fifo-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sns-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-batch-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-fifo-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-aws-sqs-sink-sink.json | 2 +- .../generated/resources/connectors/camel-aws-sqs-source-source.json | 2 +- .../src/generated/resources/connectors/camel-aws2-iam-sink.json | 4 ++-- .../src/generated/resources/connectors/camel-aws2-kms-sink.json | 4 ++-- .../resources/connectors/camel-azure-cosmosdb-source-source.json | 4 ++-- .../resources/connectors/camel-azure-eventhubs-sink-sink.json | 4 ++-- .../resources/connectors/camel-azure-eventhubs-source-source.json | 4 ++-- .../resources/connectors/camel-azure-storage-blob-sink-sink.json | 4 ++-- .../resources/connectors/camel-azure-storage-blob-source-source.json | 4 ++-- .../resources/connectors/camel-azure-storage-queue-sink-sink.json | 4 ++-- .../resources/connectors/camel-azure-storage-queue-source-source.json | 4 ++-- .../generated/resources/connectors/camel-bitcoin-source-source.json | 4 ++-- .../src/generated/resources/connectors/camel-cassandra-sink-sink.json | 2 +- .../generated/resources/connectors/camel-cassandra-source-source.json | 2 +- .../resources/connectors/camel-chuck-norris-source-source.json| 2 +- .../src/generated/resources/connectors/camel-couchbase-sink-sink.json | 4 ++-- .../src/generated/resources/connectors/camel-cron-source-source.json | 4 ++-- .../src/generated/resources/connectors/camel-cxf-sink.json| 2 +- .../src/generated/resources/connectors/camel-cxf-source.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-sink.json | 2 +- .../src/generated/resources/connectors/camel-cxfrs-source.json| 2 +- .../src/generated/resources/connectors/camel-dropbox-sink-sink.json | 4 ++-- .../generated/resources/connectors/camel-dropbox-source-source.json | 4 ++-- .../resources/connectors/camel-earthquake-source-source.json | 4 ++-- .../resources/connectors/camel-elasticsearch-index-sink-sink.json | 2 +- .../connectors/camel-elasticsearch-search-source-source.json | 4 ++-- .../src/generated/resources/connectors/camel-exec-sink-sink.json | 4 ++-- .../src/generated/resources/connectors/camel-fhir-source-source.json | 4 ++-- .../src/generated/resources/connectors/camel-file-sink.json | 2 +- .../src/generated/resources/connectors/camel-file-source.json | 2 +- .../resources/connectors/camel-file-watch-source-source.json | 2 +- .../src/generated/resources/connectors/camel-ftp-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-ftp-source-source.json | 2 +- .../src/generated/resources/connectors/camel-ftps-sink-sink.json | 2 +- .../src/generated/resources/connectors/camel-ftps-source-source.json | 2 +- .../generated/resources/connectors/camel-github-source-source.json| 4 ++-- .../resources/connectors/camel-go
[camel-kafka-connector] branch camel-kafka-connector-1.0.x updated: [maven-release-plugin] prepare for next development iteration
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-1.0.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-1.0.x by this push: new 06bfd8c [maven-release-plugin] prepare for next development iteration 06bfd8c is described below commit 06bfd8c5c1124a3f305e868507143dd531b91718 Author: Andrea Tarocchi AuthorDate: Fri Jan 14 15:23:43 2022 +0100 [maven-release-plugin] prepare for next development iteration --- .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml| 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml | 2 +- connectors/camel-earthquake-source-kafka-connector/pom.xml| 2 +- connectors/camel-elasticsearch-index-sink-kafka-connector/pom.xml | 2 +- connectors/camel-elasticsearch-search-source-kafka-connector/pom.xml | 2 +- connectors/camel-exec-sink-kafka-connector/pom.xml| 2 +- connectors/camel-fhir-source-kafka-connector/pom.xml | 2 +- connectors/camel-file-kafka-connector/pom.xml | 2 +- connectors/camel-file-watch-source-kafka-connector/pom.xml| 2 +- connectors/camel-ftp-sink-kafka-connector/pom.xml | 2 +- connectors/camel-ftp-source-kafka-connector/pom.xml | 2 +- connectors/camel-ftps-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ftps-source-kafka-connector/pom.xml | 2 +- connectors/camel-github-source-kafka-connector/pom.xml| 2 +- connectors/camel-google-calendar
[camel-kafka-connector] annotated tag camel-kafka-connector-1.0.0 created (now ca6e41c)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to annotated tag camel-kafka-connector-1.0.0 in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at ca6e41c (tag) tagging 64c8f6d7b9de4c841ae642c5879201404f54e253 (commit) replaces camel-kafka-connector-0.6.0 by Andrea Tarocchi on Fri Jan 14 15:23:39 2022 +0100 - Log - [maven-release-plugin] copy for tag camel-kafka-connector-1.0.0 --- No new revisions were added by this update.
[camel-kafka-connector] branch camel-kafka-connector-1.0.x created (now 64c8f6d)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a change to branch camel-kafka-connector-1.0.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git. at 64c8f6d [maven-release-plugin] prepare release camel-kafka-connector-1.0.0 This branch includes the following new commits: new b3ec5a3 Updated dependency to timer connector in camel-kafka-connector-extensible-archetype new 64c8f6d [maven-release-plugin] prepare release camel-kafka-connector-1.0.0 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.
[camel-kafka-connector] 02/02: [maven-release-plugin] prepare release camel-kafka-connector-1.0.0
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-1.0.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 64c8f6d7b9de4c841ae642c5879201404f54e253 Author: Andrea Tarocchi AuthorDate: Fri Jan 14 15:23:33 2022 +0100 [maven-release-plugin] prepare release camel-kafka-connector-1.0.0 --- .../camel-kafka-connector-extensible-apicurio-archetype/pom.xml | 2 +- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- .../camel-kafka-connector-extensible-dataformat-archetype/pom.xml | 2 +- archetypes/pom.xml| 2 +- buildingtools/pom.xml | 2 +- camel-kafka-connector-catalog/pom.xml | 2 +- connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-redshift-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-redshift-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-s3-source-kafka-connector/pom.xml| 2 +- connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml| 2 +- connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-iam-kafka-connector/pom.xml | 2 +- connectors/camel-aws2-kms-kafka-connector/pom.xml | 2 +- connectors/camel-azure-cosmosdb-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-eventhubs-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-eventhubs-source-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-blob-source-kafka-connector/pom.xml| 2 +- connectors/camel-azure-storage-queue-sink-kafka-connector/pom.xml | 2 +- connectors/camel-azure-storage-queue-source-kafka-connector/pom.xml | 2 +- connectors/camel-bitcoin-source-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cassandra-source-kafka-connector/pom.xml | 2 +- connectors/camel-chuck-norris-source-kafka-connector/pom.xml | 2 +- connectors/camel-couchbase-sink-kafka-connector/pom.xml | 2 +- connectors/camel-cron-source-kafka-connector/pom.xml | 2 +- connectors/camel-cxf-kafka-connector/pom.xml | 2 +- connectors/camel-cxfrs-kafka-connector/pom.xml| 2 +- connectors/camel-dropbox-sink-kafka-connector/pom.xml | 2 +- connectors/camel-dropbox-source-kafka-connector/pom.xml | 2 +- connectors/camel-earthquake-source-kafka-connector/pom.xml| 2 +- connectors/camel-elasticsearch-index-sink-kafka-connector/pom.xml | 2 +- connectors/camel-elasticsearch-search-source-kafka-connector/pom.xml | 2 +- connectors/camel-exec-sink-kafka-connector/pom.xml| 2 +- connectors/camel-fhir-source-kafka-connector/pom.xml | 2 +- connectors/camel-file-kafka-connector/pom.xml | 2 +- connectors/camel-file-watch-source-kafka-connector/pom.xml| 2 +- connectors/camel-ftp-sink-kafka-connector/pom.xml | 2 +- connectors/camel-ftp-source-kafka-connector/pom.xml | 2 +- connectors/camel-ftps-sink-kafka-connector/pom.xml| 2 +- connectors/camel-ftps-source-kafka-connector/pom.xml | 2 +- connectors/camel-github-source-kafka-connector/pom.xml| 2 +- connectors/camel-google-calendar-source-kafka-connector/pom.xml | 2 +- connectors/camel-google-functions-sink-kafka-connector/pom.xml| 2 +- connectors/camel-google-mail-source-kafka-connector/pom.xml | 2
[camel-kafka-connector] 01/02: Updated dependency to timer connector in camel-kafka-connector-extensible-archetype
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-1.0.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit b3ec5a36c25ae80340b0c8aa9b5cb2942b2048be Author: Andrea Tarocchi AuthorDate: Fri Jan 14 15:06:51 2022 +0100 Updated dependency to timer connector in camel-kafka-connector-extensible-archetype --- archetypes/camel-kafka-connector-extensible-archetype/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/archetypes/camel-kafka-connector-extensible-archetype/pom.xml b/archetypes/camel-kafka-connector-extensible-archetype/pom.xml index 89ce81d..708d9c5 100644 --- a/archetypes/camel-kafka-connector-extensible-archetype/pom.xml +++ b/archetypes/camel-kafka-connector-extensible-archetype/pom.xml @@ -35,7 +35,7 @@ org.apache.camel.kafkaconnector -camel-timer-kafka-connector +camel-timer-source-kafka-connector ${project.version} test
[camel-kamelets] branch main updated: fix #701: elasticsearch-index-sink has no way to set username and password
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git The following commit(s) were added to refs/heads/main by this push: new 60d7ed7 fix #701: elasticsearch-index-sink has no way to set username and password 60d7ed7 is described below commit 60d7ed7aa136dcd1e0b2792c76a9e5bad214a528 Author: Andrea Tarocchi AuthorDate: Wed Jan 12 16:19:30 2022 +0100 fix #701: elasticsearch-index-sink has no way to set username and password --- kamelets/elasticsearch-index-sink.kamelet.yaml | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/kamelets/elasticsearch-index-sink.kamelet.yaml b/kamelets/elasticsearch-index-sink.kamelet.yaml index 14cff85..db4761f 100644 --- a/kamelets/elasticsearch-index-sink.kamelet.yaml +++ b/kamelets/elasticsearch-index-sink.kamelet.yaml @@ -97,6 +97,9 @@ spec: beans: - name: local-es type: "#class:org.apache.camel.component.elasticsearch.ElasticsearchComponent" +properties: +user: "{{user:dummy}}" +password: "{{password:dummy}}" from: uri: kamelet:source steps: @@ -130,8 +133,6 @@ spec: operation: "INDEX" hostAddresses: "{{hostAddresses}}" enableSSL: "{{enableSSL}}" -user: "{{?user}}" -password: "{{?password}}" indexName: "{{?indexName}}" - marshal: json: { }
[camel-kafka-connector] branch camel-kafka-connector-0.11.x updated: #1308 update Antora structure
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch camel-kafka-connector-0.11.x in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/camel-kafka-connector-0.11.x by this push: new cb1c695 #1308 update Antora structure cb1c695 is described below commit cb1c695f4fcd4ec08482adab56da945a1a739453 Author: David Jencks AuthorDate: Wed Jan 5 14:56:19 2022 -0800 #1308 update Antora structure --- .../ROOT/{assets => }/images/ckc-idempotency-sink.png | Bin .../ROOT/{assets => }/images/ckc-idempotency-source.png | Bin 2 files changed, 0 insertions(+), 0 deletions(-) diff --git a/docs/modules/ROOT/assets/images/ckc-idempotency-sink.png b/docs/modules/ROOT/images/ckc-idempotency-sink.png similarity index 100% rename from docs/modules/ROOT/assets/images/ckc-idempotency-sink.png rename to docs/modules/ROOT/images/ckc-idempotency-sink.png diff --git a/docs/modules/ROOT/assets/images/ckc-idempotency-source.png b/docs/modules/ROOT/images/ckc-idempotency-source.png similarity index 100% rename from docs/modules/ROOT/assets/images/ckc-idempotency-source.png rename to docs/modules/ROOT/images/ckc-idempotency-source.png
[camel-kafka-connector] branch main updated (2b05c2a -> c7fc3c9)
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 2b05c2a Updated CHANGELOG.md add 6b7ff32 Updated to camel 3.14 and kamelet catalog 0.6.0 add 0405a49 chore: regen. add c7fc3c9 Fixed itests after regen. No new revisions were added by this update. Summary of changes: .../connectors/camel-aws-cloudwatch-sink-sink.json | 4 +- .../connectors/camel-aws-redshift-sink-sink.json | 50 .../camel-aws-redshift-source-source.json | 56 .../camel-aws-secrets-manager-sink-sink.json | 31 +++ .../connectors/camel-cassandra-sink-sink.json | 17 +- .../connectors/camel-cassandra-source-source.json | 8 +- .../connectors/camel-couchbase-sink-sink.json | 64 + .../camel-google-functions-sink-sink.json | 37 +++ .../connectors/camel-google-storage-sink-sink.json | 32 +++ .../camel-google-storage-source-source.json| 39 +++ .../connectors/camel-infinispan-sink-sink.json | 65 + .../connectors/camel-infinispan-source-source.json | 3 +- .../camel-kafka-not-secured-sink-sink.json | 4 +- .../camel-kafka-not-secured-source-source.json | 4 +- .../resources/connectors/camel-mail-sink-sink.json | 63 + .../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-pulsar-sink-sink.json | 138 + .../connectors/camel-pulsar-source-source.json | 151 ++ .../connectors/camel-redis-sink-sink.json | 46 +++ .../connectors/camel-redis-source-source.json | 46 +++ .../connectors/camel-salesforce-source-source.json | 9 +- .../resources/connectors/camel-solr-sink-sink.json | 44 +++ .../connectors/camel-solr-source-source.json | 50 .../connectors/camel-sqlserver-sink-sink.json | 2 +- .../connectors/camel-sqlserver-source-source.json | 2 +- .../resources/connectors/camel-ssh-sink-sink.json | 38 +++ .../connectors/camel-websocket-source-source.json | 117 .../connectors/camel-wttrin-source-source.json | 39 +++ .../resources/camel-aws-cloudwatch-sink-sink.json | 4 +- .../CamelAwscloudwatchsinkSinkConnector.properties | 2 +- .../CamelAwscloudwatchsinkSinkConnectorConfig.java | 8 +- .../kamelets/aws-cloudwatch-sink.kamelet.yaml | 25 +- .../kamelets/aws-ddb-streams-source.kamelet.yaml | 19 +- .../resources/kamelets/aws-ec2-sink.kamelet.yaml | 19 +- .../aws-kinesis-firehose-sink.kamelet.yaml | 19 +- .../kamelets/aws-kinesis-sink.kamelet.yaml | 19 +- .../kamelets/aws-kinesis-source.kamelet.yaml | 19 +- .../kamelets/aws-lambda-sink.kamelet.yaml | 19 +- .../pom.xml| 24 +- .../descriptors/connector-sink.properties | 1 + .../resources/camel-aws-redshift-sink-sink.json| 50 .../src/main/assembly/package.xml | 0 .../CamelAwsredshiftsinkSinkConnector.properties} | 20 +- .../CamelAwsredshiftsinkSinkConnector.java}| 8 +- .../CamelAwsredshiftsinkSinkConnectorConfig.java | 69 + .../CamelAwsredshiftsinkSinkTask.java} | 12 +- .../src/main/resources/META-INF/LICENSE.txt| 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kamelets/aws-redshift-sink.kamelet.yaml| 114 .../pom.xml| 24 +- .../descriptors/connector-source.properties| 1 + .../camel-aws-redshift-source-source.json | 56 .../src/main/assembly/package.xml | 0 ...melAwsredshiftsourceSourceConnector.properties} | 20 +- .../CamelAwsredshiftsourceSourceConnector.java}| 10 +- ...amelAwsredshiftsourceSourceConnectorConfig.java | 73 + .../CamelAwsredshiftsourceSourceTask.java} | 12 +- .../src/main/resources/META-INF/LICENSE.txt| 0 .../src/main/resources/META-INF/NOTICE.txt | 0 .../kamelets/aws-redshift-source.kamelet.yaml | 111 .../resources/kamelets/aws-s3-sink.kamelet.yaml| 19 +- .../resources/kamelets/aws-s3-source.kamelet.yaml | 2 +- .../aws-s3-streaming-upload-sink.kamelet.yaml | 23 +- .../pom.xml| 16 +- .../descriptors/connector-sink.properties | 1 + .../camel-aws-secrets-manager-sink-sink.json | 31 +++ .../src/main/assembly/package.xml | 0 ...lAwssecretsmanagersinkSinkConnector.properties} | 12 +- .../CamelAwssecretsmanagersinkSinkConnector.java} | 10 +- ...elAwssecretsmanagersinkSinkConnectorConfig.java | 57 .../CamelAwssecretsmanagersinkSinkTask.java} | 12
[camel-kafka-connector] branch main updated: #1308 update Antora structure
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new 2a94eb4 #1308 update Antora structure 2a94eb4 is described below commit 2a94eb4c2de721f84a20cc20a387cc34de881540 Author: David Jencks AuthorDate: Wed Jan 5 14:55:03 2022 -0800 #1308 update Antora structure --- .../ROOT/{assets => }/images/ckc-idempotency-sink.png | Bin .../ROOT/{assets => }/images/ckc-idempotency-source.png | Bin 2 files changed, 0 insertions(+), 0 deletions(-) diff --git a/docs/modules/ROOT/assets/images/ckc-idempotency-sink.png b/docs/modules/ROOT/images/ckc-idempotency-sink.png similarity index 100% rename from docs/modules/ROOT/assets/images/ckc-idempotency-sink.png rename to docs/modules/ROOT/images/ckc-idempotency-sink.png diff --git a/docs/modules/ROOT/assets/images/ckc-idempotency-source.png b/docs/modules/ROOT/images/ckc-idempotency-source.png similarity index 100% rename from docs/modules/ROOT/assets/images/ckc-idempotency-source.png rename to docs/modules/ROOT/images/ckc-idempotency-source.png
[camel-kafka-connector] 01/03: Update to camel 3.13.0 in preparation for releasing Set the connectors to be built mostly from kamelets
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git commit 3be28b72845ef5f4863dee4f0bbb01c7b99fc1e0 Author: Andrea Tarocchi AuthorDate: Sun Dec 5 09:09:56 2021 +0100 Update to camel 3.13.0 in preparation for releasing Set the connectors to be built mostly from kamelets --- connectors/pom.xml | 305 ++--- parent/pom.xml | 4 +- pom.xml| 2 +- 3 files changed, 14 insertions(+), 297 deletions(-) diff --git a/connectors/pom.xml b/connectors/pom.xml index 75ae12e..fc35ac1 100644 --- a/connectors/pom.xml +++ b/connectors/pom.xml @@ -89,7 +89,7 @@ - + netty,http-netty,couchbase,cxf,cxfrs,file,hdfs,jdbs,sjms2,sql @@ -103,7 +103,7 @@ ${project.basedir}/camel-kafka-connector-template-example-source-properties.template ${project.basedir}/camel-kafka-connector-template-example-sink-properties.template - +true bonita bean-validator @@ -205,25 +205,6 @@ -camel-activemq-kafka-connector -camel-ahc-kafka-connector -camel-ahc-ws-kafka-connector -camel-ahc-wss-kafka-connector -camel-amqp-kafka-connector -camel-arangodb-kafka-connector -camel-as2-kafka-connector -camel-asterisk-kafka-connector -camel-atlasmap-kafka-connector -camel-atmos-kafka-connector -camel-atmosphere-websocket-kafka-connector -camel-atom-kafka-connector -camel-atomix-map-kafka-connector -camel-atomix-messaging-kafka-connector -camel-atomix-multimap-kafka-connector -camel-atomix-queue-kafka-connector -camel-atomix-set-kafka-connector -camel-atomix-value-kafka-connector -camel-avro-kafka-connector camel-aws-cloudwatch-sink-kafka-connector camel-aws-ddb-streams-source-kafka-connector camel-aws-ec2-sink-kafka-connector @@ -234,362 +215,98 @@ camel-aws-s3-sink-kafka-connector camel-aws-s3-source-kafka-connector camel-aws-s3-streaming-upload-sink-kafka-connector -camel-aws-secrets-manager-kafka-connector camel-aws-sns-fifo-sink-kafka-connector camel-aws-sns-sink-kafka-connector camel-aws-sqs-batch-sink-kafka-connector camel-aws-sqs-fifo-sink-kafka-connector camel-aws-sqs-sink-kafka-connector camel-aws-sqs-source-kafka-connector -camel-aws2-athena-kafka-connector -camel-aws2-ddbstream-kafka-connector -camel-aws2-ecs-kafka-connector -camel-aws2-eks-kafka-connector -camel-aws2-eventbridge-kafka-connector -camel-aws2-iam-kafka-connector -camel-aws2-kinesis-firehose-kafka-connector -camel-aws2-kms-kafka-connector -camel-aws2-mq-kafka-connector -camel-aws2-msk-kafka-connector -camel-aws2-ses-kafka-connector -camel-aws2-sts-kafka-connector -camel-aws2-translate-kafka-connector -camel-azure-cosmosdb-kafka-connector +camel-azure-cosmosdb-source-kafka-connector camel-azure-eventhubs-sink-kafka-connector camel-azure-eventhubs-source-kafka-connector camel-azure-storage-blob-sink-kafka-connector camel-azure-storage-blob-source-kafka-connector -camel-azure-storage-datalake-kafka-connector camel-azure-storage-queue-sink-kafka-connector camel-azure-storage-queue-source-kafka-connector -camel-bean-kafka-connector -camel-beanstalk-kafka-connector camel-bitcoin-source-kafka-connector -camel-box-kafka-connector -camel-braintree-kafka-connector -camel-caffeine-cache-kafka-connector -camel-caffeine-loadcache-kafka-connector camel-cassandra-sink-kafka-connector camel-cassandra-source-kafka-connector -camel-chatscript-kafka-connector camel-chuck-norris-source-kafka-connector -camel-chunk-kafka-connector -camel-cm-sms-kafka-connector -camel-cmis-kafka-connector -camel-coap-kafka-connector -camel-coap-tcp-kafka-connector -camel-coaps-kafka-connector -camel-coaps-tcp-kafka-connector -camel-cometd-kafka-connector -camel-cometds-kafka-connector -camel-consul-kafka-connector -camel-controlbus-kafka-connector -camel-corda-kafka-connector camel-couchbase-kafka-connector -camel-couchdb-kafka-connector -camel-cql-kafka-connector camel-cron-source-kafka-connector
[camel] 02/02: chore(checkstyle): fixed missing file header
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit c5b9a74eb9072ebaf22b98617cb99b88524816fb Author: Andrea Tarocchi AuthorDate: Tue Nov 30 22:06:39 2021 +0100 chore(checkstyle): fixed missing file header --- .../org/apache/camel/health/HealthCheckResolver.java | 16 1 file changed, 16 insertions(+) diff --git a/core/camel-api/src/main/java/org/apache/camel/health/HealthCheckResolver.java b/core/camel-api/src/main/java/org/apache/camel/health/HealthCheckResolver.java index 35f71af..342102a 100644 --- a/core/camel-api/src/main/java/org/apache/camel/health/HealthCheckResolver.java +++ b/core/camel-api/src/main/java/org/apache/camel/health/HealthCheckResolver.java @@ -1,3 +1,19 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.camel.health; import org.apache.camel.CamelContextAware;
[camel] branch main updated (651645b -> c5b9a74)
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.git. from 651645b rewrite improving-the-documentation.adoc new e9a36d0 [CAMEL-17252] fix Error in KameletYamlRoutes while loading routes based on kemelets without dependencies. new c5b9a74 chore(checkstyle): fixed missing file header 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: .../org/apache/camel/health/HealthCheckResolver.java | 16 .../java/org/apache/camel/main/KameletYamlRoutes.java| 2 +- 2 files changed, 17 insertions(+), 1 deletion(-)
[camel] 01/02: [CAMEL-17252] fix Error in KameletYamlRoutes while loading routes based on kemelets without dependencies.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git commit e9a36d01823b995313a018f35c10cb535d79090d Author: Andrea Tarocchi AuthorDate: Tue Nov 30 21:53:03 2021 +0100 [CAMEL-17252] fix Error in KameletYamlRoutes while loading routes based on kemelets without dependencies. --- .../src/main/java/org/apache/camel/main/KameletYamlRoutes.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletYamlRoutes.java b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletYamlRoutes.java index 93f6c71..81ab568 100644 --- a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletYamlRoutes.java +++ b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/KameletYamlRoutes.java @@ -63,7 +63,7 @@ class KameletYamlRoutes extends YamlRoutesBuilderLoaderSupport implements CamelC final List dependencies = new ArrayList<>(); Node deps = nodeAt(node, "/spec/dependencies"); -if (deps.getNodeType() == NodeType.SEQUENCE) { +if (deps != null && deps.getNodeType() == NodeType.SEQUENCE) { SequenceNode sn = (SequenceNode) deps; for (Node child : sn.getValue()) { if (child.getNodeType() == NodeType.SCALAR) {
[camel-kamelets] branch main updated: fix: use the right json schema type for integers (#575)
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git The following commit(s) were added to refs/heads/main by this push: new 8187e83 fix: use the right json schema type for integers (#575) 8187e83 is described below commit 8187e8333a342afb25cf9d98282b9b8d0326555f Author: Luca Burgazzoli AuthorDate: Mon Nov 22 11:28:09 2021 +0100 fix: use the right json schema type for integers (#575) --- aws-s3-streaming-upload-sink.kamelet.yaml | 4 ++-- azure-storage-queue-source.kamelet.yaml | 2 +- couchbase-sink.kamelet.yaml | 2 +- .../main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml | 4 ++-- .../main/resources/kamelets/azure-storage-queue-source.kamelet.yaml | 2 +- .../src/main/resources/kamelets/couchbase-sink.kamelet.yaml | 2 +- .../src/main/resources/kamelets/throttle-action.kamelet.yaml | 4 ++-- throttle-action.kamelet.yaml | 4 ++-- 8 files changed, 12 insertions(+), 12 deletions(-) diff --git a/aws-s3-streaming-upload-sink.kamelet.yaml b/aws-s3-streaming-upload-sink.kamelet.yaml index ded18ef..831cab6 100644 --- a/aws-s3-streaming-upload-sink.kamelet.yaml +++ b/aws-s3-streaming-upload-sink.kamelet.yaml @@ -70,12 +70,12 @@ spec: batchMessageNumber: title: Batch Message Number description: The number of messages composing a batch in streaming upload mode -type: int +type: integer default: 10 batchSize: title: Batch Size description: The batch size (in bytes) in streaming upload mode -type: int +type: integer default: '100' streamingUploadTimeout: title: Streaming Upload Timeout diff --git a/azure-storage-queue-source.kamelet.yaml b/azure-storage-queue-source.kamelet.yaml index 626d5f4..b5c8dab 100644 --- a/azure-storage-queue-source.kamelet.yaml +++ b/azure-storage-queue-source.kamelet.yaml @@ -42,7 +42,7 @@ spec: maxMessages: title: Maximum Messages description: Maximum number of messages to get, if there are less messages exist in the queue than requested all the messages will be returned. By default it will consider 1 message to be retrieved, the allowed range is 1 to 32 messages. -type: int +type: integer default: 1 dependencies: - "camel:azure-storage-queue" diff --git a/couchbase-sink.kamelet.yaml b/couchbase-sink.kamelet.yaml index e0b97f1..a227fbd 100644 --- a/couchbase-sink.kamelet.yaml +++ b/couchbase-sink.kamelet.yaml @@ -32,7 +32,7 @@ spec: couchbasePort: title: Port description: The port to use -type: int +type: integer default: 8091 bucket: title: Bucket diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml index ded18ef..831cab6 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml @@ -70,12 +70,12 @@ spec: batchMessageNumber: title: Batch Message Number description: The number of messages composing a batch in streaming upload mode -type: int +type: integer default: 10 batchSize: title: Batch Size description: The batch size (in bytes) in streaming upload mode -type: int +type: integer default: '100' streamingUploadTimeout: title: Streaming Upload Timeout diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-queue-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-queue-source.kamelet.yaml index 626d5f4..b5c8dab 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-queue-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-queue-source.kamelet.yaml @@ -42,7 +42,7 @@ spec: maxMessages: title: Maximum Messages description: Maximum number of messages to get, if there are less messages exist in the queue than requested all the messages will be returned. By default it will consider 1 message to be retrieved, the allowed range is 1 to 32 messages. -type: int +type: integer default: 1 dependencies: - "camel:azure-storage-queue" diff --git a/library/camel-kamelets/src/main/resources/kamelets/couchbase-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/couchbase-sink.kamelet.yaml index e0b
[camel-kafka-connector] branch main updated: chore: regen.
This is an automated email from the ASF dual-hosted git repository. valdar pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git The following commit(s) were added to refs/heads/main by this push: new 0fe96d7 chore: regen. 0fe96d7 is described below commit 0fe96d7dd2f664940e798c95b3c485a6a9f14377 Author: Andrea Tarocchi AuthorDate: Sun Oct 31 01:57:05 2021 +0200 chore: regen. --- connectors/pom.xml | 3 + docs/modules/ROOT/nav.adoc | 112 --- docs/modules/ROOT/pages/reference/index.adoc | 44 +-- 3 files changed, 4 insertions(+), 155 deletions(-) diff --git a/connectors/pom.xml b/connectors/pom.xml index 1318df7..75ae12e 100644 --- a/connectors/pom.xml +++ b/connectors/pom.xml @@ -120,6 +120,9 @@ ref robotframework + +syslog + diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc index 8e2642e..b4aa73f 100644 --- a/docs/modules/ROOT/nav.adoc +++ b/docs/modules/ROOT/nav.adoc @@ -111,14 +111,8 @@ xref:reference/connectors/camel-aws-sqs-source-kafka-source-connector.adoc[Source Docs] *** camel-aws2-athena-kafka-connector xref:reference/connectors/camel-aws2-athena-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-cw-kafka-connector - xref:reference/connectors/camel-aws2-cw-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-ddb-kafka-connector - xref:reference/connectors/camel-aws2-ddb-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-ddbstream-kafka-connector xref:reference/connectors/camel-aws2-ddbstream-kafka-source-connector.adoc[Source Docs] -*** camel-aws2-ec2-kafka-connector - xref:reference/connectors/camel-aws2-ec2-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-ecs-kafka-connector xref:reference/connectors/camel-aws2-ecs-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-eks-kafka-connector @@ -129,27 +123,14 @@ xref:reference/connectors/camel-aws2-iam-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-kinesis-firehose-kafka-connector xref:reference/connectors/camel-aws2-kinesis-firehose-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-kinesis-kafka-connector - xref:reference/connectors/camel-aws2-kinesis-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-aws2-kinesis-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-kms-kafka-connector xref:reference/connectors/camel-aws2-kms-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-lambda-kafka-connector - xref:reference/connectors/camel-aws2-lambda-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-mq-kafka-connector xref:reference/connectors/camel-aws2-mq-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-msk-kafka-connector xref:reference/connectors/camel-aws2-msk-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-s3-kafka-connector - xref:reference/connectors/camel-aws2-s3-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-aws2-s3-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-ses-kafka-connector xref:reference/connectors/camel-aws2-ses-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-sns-kafka-connector - xref:reference/connectors/camel-aws2-sns-kafka-sink-connector.adoc[Sink Docs] -*** camel-aws2-sqs-kafka-connector - xref:reference/connectors/camel-aws2-sqs-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-aws2-sqs-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-sts-kafka-connector xref:reference/connectors/camel-aws2-sts-kafka-sink-connector.adoc[Sink Docs] *** camel-aws2-translate-kafka-connector @@ -157,16 +138,10 @@ *** camel-azure-cosmosdb-kafka-connector xref:reference/connectors/camel-azure-cosmosdb-kafka-source-connector.adoc[Source Docs] xref:reference/connectors/camel-azure-cosmosdb-kafka-sink-connector.adoc[Sink Docs] -*** camel-azure-eventhubs-kafka-connector - xref:reference/connectors/camel-azure-eventhubs-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-azure-eventhubs-kafka-sink-connector.adoc[Sink Docs] *** camel-azure-eventhubs-sink-kafka-connector xref:reference/connectors/camel-azure-eventhubs-sink-kafka-sink-connector.adoc[Sink Docs] *** camel-azure-eventhubs-source-kafka-connector xref:reference/connectors/camel-azure-eventhubs-source-kafka-source-connector.adoc[Source Docs] -*** camel-azure-storage-blob-kafka-connector - xref:reference/connectors/camel-azure-storage-blob-kafka-source-connector.adoc[Source Docs] - xref:reference/connectors/camel-azure-storage-blob-kafka-sink-connector.adoc[Sink Docs] *** camel-azure-storage-blob-sink