You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2021/02/05 03:32:50 UTC
[camel-kafka-connector] branch automatic-periodic-sync updated
(936a975 -> 8dc13d6)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch automatic-periodic-sync
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
omit 936a975 [create-pull-request] automated change
omit 0d0fd7c [create-pull-request] automated change
omit 4794e96 Fixed codestyle
omit c239f28 Fix DataformatTest assertion
omit 84be03b [create-pull-request] automated change
omit 65fe36a [create-pull-request] automated change
omit 6848963 [create-pull-request] automated change
omit 210b54f Avoid slashes on RabbitMQ component
omit 3639e14 Avoid slashes in sjms2 URLs
omit 37f2c75 Fix issue #159: camel components secret options are showed in logs
omit d198f85 Bump camel dependency to use the latest 3.8.0-SNAPSHOT
add 524fc20 Updates SSH tests to Camel's 3.7 test infra interfaces
add 95392d6 Added SchemaAndStructToJsonTransform fix #843
add 987a5f9 Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest
add 61a7234 Added a test to make sure we retain original exception data on errors
add ce6cbb3 (chores) Cleanup topic deletion code and allow public access to the admin client
add f3903be Ensures that Couchbase client dependencies are packed with the connector (GH issue #878)
add ce983d5 Bump to Kafka 2.7.0
add 5b780f9 Upgrade Scala Library to version 2.12.12
add d39a390 Mark HDFS Integration test as slow
add a2949c2 Fixed imports
add 34694e1 Fixed checkstyle
add 854d4fe AWS2-Kinesis connector: Add a transformation to extract only the data from a source stream
add 6fc708e Regen documentation
add c5193cb Fixed CS
add 87661a9 Modify the Github Actions configuration to allow archiving test logs (#882)
add ba7091d Upgrade Strimzi to version 0.21.0.kafka-2.7.0
add 670b2b0 Always run the archiving step so we can have log files on failure and cancelled
add 094776d Fix using an incorrect format for the continuity check logic
add 29f6fa5 Bump Apicurio Registry to version 1.3.2.Final
add e2d32e8 Fix HDFS compatibility issues with Jetty deps on camel-hdfs
add e5038e7 Move HDFS tests to the default set after fixing the HDFS test incompatibilities
add 9c9a8f9 Compatibility matrix: added ckc 0.7.0
add 198bf2f Bump Strimzi to version 0.21.1
add 7b0a1eb Add a column to compatibility matrix about Kafka version
add cf776d4 Fixed version in compatibility matrix for 0.6.1
add e1d54c1 Removed unused HDFS test files that were migrated to camel-test-infra
add 062a02c (chores) Cleanup unused annotations
add 4ea52dc Strimzi project is now using Quay for their images
add 47cac0e Added new daily JDK 14 build on github actions
add fb19034 Camel-Cron connector: We need to add at least camel-quartz as dependency
add 11ca8b0 Created a base test class for AWS sink tests
add 6a78354 Simplified handling of setting common AWS 2 properties
add c7a6b0f Added new integration test for AWS 2 Cloud Watch
add ba46490 (chores) fixed typo in AWS v2 Cloud Watch test
add db4fa44 Added new integration test for AWS 2 EC2
add e212370 Added AWS v2 IAM sink test case
add 15cc5ce Prevent matrix jobs from rewriting the archived log on github actions
add c96d796 Fix link in idempotency.adoc
add cce09f4 Added AWS v2 Kinesis sink test case
add 4bb910e Fix table doc and rename connecotr word
add 0f83785 Java 14: upgrade plugins to versions that support Java 14
add 16270d5 Java 14: update the connector version used in test to one that supports Java 14
add c4c22c9 Java 14: update the mvel2 version to one that supports Java 14
add 591cf3b Java 14: re-order archetypes module to avoid a cyclic dependency between modules
add 572389b Use an assembly plugin version that is supported by java 14
add 6cc3b6d Java 14: bump Groovy version to the same one used in Camel
add 73e4d44 Java 14: added the new supported Java version to the build matrix
add 8735179 Removes the daily JDK 14 github action because it is already being run on the default CI action
add b6156c2 Added a daily workflow for building with newer Java versions (#928)
add a108cf1 Add a map Camel Properties to Kafka headers option to make the behavior configurable
add 005cb69 Fixed CS
add 676b86a Added AWS v2 KMS sink test case
add 513f1e2 Added AWS v2 S3 sink test case
add a111609 Upgrade docs to 0.7.1 as latest release
add 96dd421 Regen
add 7e30724 Upgrade archetype instructions to version 0.8.0
add a024c7c create a toHeader SMT #902
add 3c9b5f8 Add a map Camel Headers to Kafka headers option to make the behavior configurable
add 8aeaaf1 Fixed CS
add c116cce Added Azure Storage Queue source test case
add fb49b9a Provide option to delete camel kafka submodule if they are not in camel catalog
add 628af19 Added an example of backport yml action
add 130a870 Backport action test: Fixed some grammar on README
add 7de2056 The backport action is not allowed in ASF
add e903409 Added backport actions as submodule
add be952d3 Revert "The backport action is not allowed in ASF"
add 5534f9b Modified the backport action to use submodule
add 577e74d Update documentation for testing backport action
add 83ec6ab Fixed backport.yml
add 2931f69 Backport.yml updated
add d45cd0b Backport yml
add c807f6a Point backport action to v1.1.0
add c5cb623 Test for Backport action - DO NOT MERGE
add 5a28e24 Upgrade Camel to 3.8.0-SNAPSHOT
add 70911aa Fix issue #159: camel components secret options are showed in logs
add dbbaa43 Avoid slashes in sjms2 URLs
add e022e3c Avoid slashes on RabbitMQ component
add 0cb2a6f Removed newline from README
add fd448a6 Remove rebase camel-master on master, it is too buggy
add e37371c Removed node setup from backport action
add fbf9941 Backport action: Added license
add 6120ea8 Changelog action added as submodule
add d7a3b2e Revert "Remove Github changelog action"
add 75af106 Changelog action modified to work with submodule
add cfc6467 Camel-master tests: Fixed dataformat
add 4b7ba49 Added a basic test for idempotency
add 55ca7a2 Avoid reusing the same destination name for the sjms2 idempotency tests
add 4b5dace Added idempotency test for SJMS2 using header expressions
add e51226e Add connector entries to doc nav
add ad8d0a9 SJMS2 itests: Avoid creating a new consumer for every message received
add aaf1946 Make the AWS v2 sink test support reusable
add c0e8ec1 Convert the AWS v1 tests to the new reusable sink test base class
add e84c8c9 Convert the Azure storage blob tests to the new reusable sink test base class
add 995b807 Convert the Azure storage queue tests to the new reusable sink test base class
add b9b2fa0 Convert the Cassandra tests to the new reusable sink test base class
add 51e7446 Convert the Couchbase tests to the new reusable sink test base class
add 34dec6e Convert the ElasticSearch tests to the new reusable sink test base class
add 6cdd1de Convert the File tests to the new reusable sink test base class
add 2331048 Convert the HDFS tests to the new reusable sink test base class
add 4f155bc Convert the HTTP tests to the new reusable sink test base class
add 114dfe5 Convert the JDBC tests to the new reusable sink test base class
add 66ef021 Convert the MongoDB tests to the new reusable sink test base class
add 16063c8 Convert the RabbitMQ tests to the new reusable sink test base class
add 525def9 Removed unused variables from SJMS2 DQL sink test
add f2dc1aa Convert the SJMS2 tests to the new reusable sink test base class
add fd4565b Convert the SQL tests to the new reusable sink test base class
add f3cd060 Convert the SSH tests to the new reusable sink test base class
add ad4a4f8 Convert the Syslog tests to the new reusable sink test base class
add b7c040b Fix error message check for SJMS2 startup on error test
add 61fab49 Temporarily disabled a error handling test for SJMS2 due to failures on GH actions
add 8db432a Disabled MongoDB source test case due to GH issue #974
add a0a30e7 Disabled Azure storage queue tests due to GH issue #976
add 9625df1 Make producing test messages for sink tests more flexible
add 8dc13d6 [create-pull-request] automated change
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 (936a975)
\
N -- N -- N refs/heads/automatic-periodic-sync (8dc13d6)
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:
.github/actions/backport | 1 +
.github/actions/changelog | 1 +
.github/workflows/automatic-changelog-update.yml | 59 ++
.github/workflows/automatic-sync-camel-master.yml | 6 +
.github/workflows/backport.yml | 38 +
.github/workflows/ci-build.yml | 8 +-
...r-onto-camel-master.yml => daily-java-next.yml} | 40 +-
.gitmodules | 6 +
README.adoc | 2 +-
.../archetype.properties | 2 +-
.../resources/connectors/camel-aws-s3-source.json | 12 +
.../connectors/camel-aws2-kinesis-sink.json | 5 +-
.../connectors/camel-aws2-kinesis-source.json | 5 +-
.../resources/connectors/camel-aws2-s3-source.json | 12 +
.../resources/connectors/camel-aws2-sns-sink.json | 4 +-
.../resources/connectors/camel-direct-sink.json | 7 +
.../resources/connectors/camel-direct-source.json | 7 +
.../connectors/camel-infinispan-sink.json | 16 +-
.../connectors/camel-infinispan-source.json | 58 +-
.../resources/connectors/camel-jslt-sink.json | 25 +-
.../resources/connectors/camel-kafka-sink.json | 6 +
.../resources/connectors/camel-kafka-source.json | 6 +
.../connectors/camel-paho-mqtt5-sink.json | 406 ---------
.../connectors/camel-paho-mqtt5-source.json | 423 ----------
.../resources/connectors/camel-pulsar-sink.json | 7 -
.../resources/connectors/camel-pulsar-source.json | 7 -
.../connectors/camel-salesforce-sink.json | 32 +-
.../connectors/camel-salesforce-source.json | 12 +
.../connectors/camel-spring-rabbitmq-sink.json | 149 ----
.../connectors/camel-spring-rabbitmq-source.json | 319 --------
.../resources/connectors/camel-sql-sink.json | 2 +-
.../resources/connectors/camel-sql-source.json | 2 +-
.../connectors/camel-vertx-kafka-sink.json | 12 +
.../connectors/camel-vertx-kafka-source.json | 12 +
.../resources/descriptors/connectors.properties | 8 +
.../generated/resources/camel-aws-s3-source.json | 12 +
.../docs/camel-aws-s3-kafka-source-connector.adoc | 4 +-
.../awss3/CamelAwss3SourceConnectorConfig.java | 8 +
.../resources/camel-aws2-kinesis-sink.json | 5 +-
.../resources/camel-aws2-kinesis-source.json | 5 +-
.../camel-aws2-kinesis-kafka-sink-connector.adoc | 9 +-
.../camel-aws2-kinesis-kafka-source-connector.adoc | 9 +-
.../transformers/KinesisRecordDataTransforms.java | 70 ++
.../generated/resources/camel-aws2-s3-source.json | 12 +
.../docs/camel-aws2-s3-kafka-source-connector.adoc | 4 +-
.../aws2s3/CamelAws2s3SourceConnectorConfig.java | 8 +
.../generated/resources/camel-aws2-sns-sink.json | 4 +-
.../docs/camel-aws2-sns-kafka-sink-connector.adoc | 4 +-
.../aws2sns/CamelAws2snsSinkConnectorConfig.java | 4 +-
.../pom.xml | 8 +-
.../descriptors/connector-sink.properties | 1 +
.../descriptors/connector-source.properties | 1 +
.../camel-azure-storage-datalake-sink.json | 416 ++++++++++
.../camel-azure-storage-datalake-source.json | 411 ++++++++++
.../src/main/assembly/package.xml | 0
...zure-storage-datalake-kafka-sink-connector.adoc | 118 +++
...re-storage-datalake-kafka-source-connector.adoc | 118 +++
...melAzurestoragedatalakeSinkConnector.properties | 21 +-
...lAzurestoragedatalakeSourceConnector.properties | 21 +-
.../CamelAzurestoragedatalakeSinkConnector.java | 40 +-
...melAzurestoragedatalakeSinkConnectorConfig.java | 305 +++++++
.../CamelAzurestoragedatalakeSinkTask.java | 39 +
.../CamelAzurestoragedatalakeSourceConnector.java | 40 +-
...lAzurestoragedatalakeSourceConnectorConfig.java | 305 +++++++
.../CamelAzurestoragedatalakeSourceTask.java | 39 +
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
connectors/camel-cron-kafka-connector/pom.xml | 4 +
.../src/generated/resources/camel-direct-sink.json | 7 +
.../generated/resources/camel-direct-source.json | 7 +
.../docs/camel-direct-kafka-sink-connector.adoc | 3 +-
.../docs/camel-direct-kafka-source-connector.adoc | 3 +-
.../direct/CamelDirectSinkConnectorConfig.java | 4 +
.../direct/CamelDirectSourceConnectorConfig.java | 4 +
.../pom.xml | 8 +-
.../descriptors/connector-sink.properties | 1 +
.../resources/camel-hwcloud-smn-sink.json | 114 +++
.../src/main/assembly/package.xml | 0
.../camel-hwcloud-smn-kafka-sink-connector.adoc | 69 ++
.../CamelHwcloudsmnSinkConnector.properties | 32 +-
.../hwcloudsmn/CamelHwcloudsmnSinkConnector.java | 38 +-
.../CamelHwcloudsmnSinkConnectorConfig.java | 108 +++
.../hwcloudsmn/CamelHwcloudsmnSinkTask.java | 46 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../pom.xml | 8 +-
.../descriptors/connector-sink.properties | 1 +
.../descriptors/connector-source.properties | 1 +
.../resources/camel-infinispan-embedded-sink.json} | 182 +----
.../camel-infinispan-embedded-source.json | 199 +++++
.../src/main/assembly/package.xml | 0
...l-infinispan-embedded-kafka-sink-connector.adoc | 82 ++
...infinispan-embedded-kafka-source-connector.adoc | 82 ++
...CamelInfinispanembeddedSinkConnector.properties | 22 +-
...melInfinispanembeddedSourceConnector.properties | 22 +-
.../CamelInfinispanembeddedSinkConnector.java | 38 +-
...CamelInfinispanembeddedSinkConnectorConfig.java | 161 ++++
.../CamelInfinispanembeddedSinkTask.java | 39 +
.../CamelInfinispanembeddedSourceConnector.java | 40 +-
...melInfinispanembeddedSourceConnectorConfig.java | 161 ++++
.../CamelInfinispanembeddedSourceTask.java | 39 +
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../generated/resources/camel-infinispan-sink.json | 16 +-
.../resources/camel-infinispan-source.json | 58 +-
.../camel-infinispan-kafka-sink-connector.adoc | 16 +-
.../camel-infinispan-kafka-source-connector.adoc | 24 +-
.../CamelInfinispanSinkConnectorConfig.java | 16 +-
.../CamelInfinispanSourceConnectorConfig.java | 40 +-
.../src/generated/resources/camel-jslt-sink.json | 25 +-
.../main/docs/camel-jslt-kafka-sink-connector.adoc | 6 +-
.../jslt/CamelJsltSinkConnectorConfig.java | 16 +-
...r.txt => camel-kafka-connector-java-header.txt} | 0
.../src/generated/resources/camel-kafka-sink.json | 6 +
.../generated/resources/camel-kafka-source.json | 6 +
.../docs/camel-kafka-kafka-sink-connector.adoc | 3 +-
.../docs/camel-kafka-kafka-source-connector.adoc | 3 +-
.../kafka/CamelKafkaSinkConnectorConfig.java | 4 +
.../kafka/CamelKafkaSourceConnectorConfig.java | 4 +
.../pom.xml | 8 +-
.../descriptors/connector-sink.properties | 1 +
.../descriptors/connector-source.properties | 1 +
.../generated/resources/camel-kamelet-sink.json} | 54 +-
.../generated/resources/camel-kamelet-source.json | 42 +-
.../src/main/assembly/package.xml | 0
.../docs/camel-kamelet-kafka-sink-connector.adoc | 65 ++
.../docs/camel-kamelet-kafka-source-connector.adoc | 62 ++
.../examples/CamelKameletSinkConnector.properties | 23 +-
.../CamelKameletSourceConnector.properties | 23 +-
.../kamelet/CamelKameletSinkConnector.java | 38 +-
.../kamelet/CamelKameletSinkConnectorConfig.java | 90 ++
.../kamelet/CamelKameletSinkTask.java | 46 +-
.../kamelet/CamelKameletSourceConnector.java | 38 +-
.../kamelet/CamelKameletSourceConnectorConfig.java | 80 ++
.../kamelet/CamelKameletSourceTask.java | 46 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../src/generated/resources/camel-pulsar-sink.json | 7 -
.../generated/resources/camel-pulsar-source.json | 7 -
.../docs/camel-pulsar-kafka-sink-connector.adoc | 3 +-
.../docs/camel-pulsar-kafka-source-connector.adoc | 3 +-
.../pulsar/CamelPulsarSinkConnectorConfig.java | 4 -
.../pulsar/CamelPulsarSourceConnectorConfig.java | 4 -
.../generated/resources/camel-salesforce-sink.json | 32 +-
.../resources/camel-salesforce-source.json | 12 +
.../camel-salesforce-kafka-sink-connector.adoc | 6 +-
.../camel-salesforce-kafka-source-connector.adoc | 4 +-
.../CamelSalesforceSinkConnectorConfig.java | 10 +-
.../CamelSalesforceSourceConnectorConfig.java | 8 +
.../resources/camel-spring-rabbitmq-sink.json | 2 +-
.../resources/camel-spring-rabbitmq-source.json | 2 +-
...camel-spring-rabbitmq-kafka-sink-connector.adoc | 4 +
...mel-spring-rabbitmq-kafka-source-connector.adoc | 4 +
.../src/generated/resources/camel-sql-sink.json | 2 +-
.../src/generated/resources/camel-sql-source.json | 2 +-
.../main/docs/camel-sql-kafka-sink-connector.adoc | 2 +-
.../docs/camel-sql-kafka-source-connector.adoc | 2 +-
.../sql/CamelSqlSinkConnectorConfig.java | 2 +-
.../sql/CamelSqlSourceConnectorConfig.java | 2 +-
.../pom.xml | 8 +-
.../descriptors/connector-sink.properties | 1 +
.../src/generated/resources/camel-stitch-sink.json | 140 ++++
.../src/main/assembly/package.xml | 0
.../docs/camel-stitch-kafka-sink-connector.adoc | 72 ++
.../examples/CamelStitchSinkConnector.properties | 25 +-
.../stitch/CamelStitchSinkConnector.java | 38 +-
.../stitch/CamelStitchSinkConnectorConfig.java | 118 +++
.../kafkaconnector/stitch/CamelStitchSinkTask.java | 46 +-
.../src/main/resources/META-INF/LICENSE.txt | 0
.../src/main/resources/META-INF/NOTICE.txt | 0
.../resources/camel-vertx-kafka-sink.json | 12 +
.../resources/camel-vertx-kafka-source.json | 12 +
.../camel-vertx-kafka-kafka-sink-connector.adoc | 4 +-
.../camel-vertx-kafka-kafka-source-connector.adoc | 4 +-
.../CamelVertxkafkaSinkConnectorConfig.java | 8 +
.../CamelVertxkafkaSourceConnectorConfig.java | 8 +
connectors/pom.xml | 7 +-
.../camel/kafkaconnector/CamelConnectorConfig.java | 8 +
.../kafkaconnector/CamelSinkConnectorConfig.java | 4 +-
.../apache/camel/kafkaconnector/CamelSinkTask.java | 12 +-
.../kafkaconnector/CamelSourceConnectorConfig.java | 4 +-
.../camel/kafkaconnector/CamelSourceTask.java | 17 +-
.../transforms/FieldsToHeadersTransform.java | 192 +++++
.../transforms/SchemaAndStructToJsonTransform.java | 77 ++
.../camel/kafkaconnector/CamelSinkTaskTest.java | 118 +++
.../camel/kafkaconnector/CamelSourceTaskTest.java | 49 ++
.../transforms/FieldsToHeadersTransformTest.java | 349 ++++++++
...ava => SchemaAndStructToJsonTransformTest.java} | 45 +-
.../SinkPojoToSchemaAndStructTransformTest.java | 3 +-
docs/modules/ROOT/nav.adoc | 903 +++++++++++++++++++++
.../ROOT/pages/archetype-apicurio-connector.adoc | 18 +-
docs/modules/ROOT/pages/archetype-connector.adoc | 16 +-
.../ROOT/pages/archetype-dataformat-connector.adoc | 18 +-
.../ROOT/pages/camel-compatibility-matrix.adoc | 23 +-
docs/modules/ROOT/pages/connectors.adoc | 709 ++++++++--------
.../camel-aws-s3-kafka-source-connector.adoc | 4 +-
.../camel-aws2-kinesis-kafka-sink-connector.adoc | 9 +-
.../camel-aws2-kinesis-kafka-source-connector.adoc | 9 +-
.../camel-aws2-s3-kafka-source-connector.adoc | 4 +-
.../camel-aws2-sns-kafka-sink-connector.adoc | 4 +-
...zure-storage-datalake-kafka-sink-connector.adoc | 118 +++
...re-storage-datalake-kafka-source-connector.adoc | 118 +++
.../camel-direct-kafka-sink-connector.adoc | 3 +-
.../camel-direct-kafka-source-connector.adoc | 3 +-
.../camel-hwcloud-smn-kafka-sink-connector.adoc | 69 ++
...l-infinispan-embedded-kafka-sink-connector.adoc | 82 ++
...infinispan-embedded-kafka-source-connector.adoc | 82 ++
.../camel-infinispan-kafka-sink-connector.adoc | 16 +-
.../camel-infinispan-kafka-source-connector.adoc | 24 +-
.../camel-jslt-kafka-sink-connector.adoc | 6 +-
.../camel-kafka-kafka-sink-connector.adoc | 3 +-
.../camel-kafka-kafka-source-connector.adoc | 3 +-
.../camel-kamelet-kafka-sink-connector.adoc | 65 ++
.../camel-kamelet-kafka-source-connector.adoc | 62 ++
.../camel-pulsar-kafka-sink-connector.adoc | 3 +-
.../camel-pulsar-kafka-source-connector.adoc | 3 +-
.../camel-salesforce-kafka-sink-connector.adoc | 6 +-
.../camel-salesforce-kafka-source-connector.adoc | 4 +-
...camel-spring-rabbitmq-kafka-sink-connector.adoc | 4 +
...mel-spring-rabbitmq-kafka-source-connector.adoc | 4 +
.../connectors/camel-sql-kafka-sink-connector.adoc | 2 +-
.../camel-sql-kafka-source-connector.adoc | 2 +-
.../camel-stitch-kafka-sink-connector.adoc | 72 ++
.../camel-vertx-kafka-kafka-sink-connector.adoc | 4 +-
.../camel-vertx-kafka-kafka-source-connector.adoc | 4 +-
docs/modules/ROOT/pages/idempotency.adoc | 2 +-
parent/pom.xml | 19 +-
pom.xml | 2 +-
.../aws/v1/sns/sink/CamelSinkAWSSNSITCase.java | 125 ++-
.../aws/v1/sqs/sink/CamelSinkAWSSQSITCase.java | 124 +--
tests/itests-aws-v2/pom.xml | 20 +
.../aws/v2/common/AWSPropertiesUtils.java | 63 ++
.../aws/v2/cw/sink/CamelAWSCWPropertyFactory.java | 73 ++
.../aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 158 ++++
.../sink/TestCloudWatchConfiguration.java} | 18 +-
.../v2/ec2/sink/CamelAWSEC2PropertyFactory.java | 73 ++
.../aws/v2/ec2/sink/CamelSinkAWSEC2ITCase.java | 151 ++++
.../sink/TestEC2Configuration.java} | 18 +-
.../v2/iam/sink/CamelAWSIAMPropertyFactory.java | 73 ++
.../aws/v2/iam/sink/CamelSinkAWSIAMITCase.java | 142 ++++
.../sink/TestIAMConfiguration.java} | 18 +-
.../KinesisUtils.java} | 167 +---
.../TestKinesisConfiguration.java | 2 +-
.../CamelAWSKinesisPropertyFactory.java | 32 +-
.../v2/kinesis/sink/CamelSinkAWSKinesisITCase.java | 155 ++++
.../source/CamelAWSKinesisPropertyFactory.java | 15 +-
.../source/CamelSourceAWSKinesisITCase.java | 164 +---
.../v2/kms/sink/CamelAWSKMSPropertyFactory.java | 73 ++
.../aws/v2/kms/sink/CamelSinkAWSKMSITCase.java | 158 ++++
.../sink/TestKMS2Configuration.java} | 18 +-
.../kafkaconnector/aws/v2/s3/common/S3Utils.java | 97 +++
.../s3/{source => common}/TestS3Configuration.java | 2 +-
.../CamelAWSS3PropertyFactory.java | 50 +-
.../aws/v2/s3/sink/CamelSinkAWSS3ITCase.java | 160 ++++
.../v2/s3/source/CamelAWSS3PropertyFactory.java | 15 +-
.../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 52 +-
.../v2/sqs/sink/CamelAWSSQSPropertyFactory.java | 26 +-
.../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 72 +-
.../v2/sqs/source/CamelAWSSQSPropertyFactory.java | 25 +-
.../blob/sink/CamelSinkAzureStorageBlobITCase.java | 105 +--
.../{sink => common}/TestQueueConfiguration.java | 2 +-
.../sink/CamelSinkAzureStorageQueueITCase.java | 79 +-
.../CamelSourceAzureStorageQueueITCase.java} | 98 +--
...amelSourceAzureStorageQueuePropertyFactory.java | 52 ++
.../cassandra/sink/CamelSinkCassandraITCase.java | 79 +-
.../kafkaconnector/common/AbstractKafkaTest.java | 5 +
.../common/BasicConnectorPropertyFactory.java | 6 +-
.../common/IdempotencyConfigBuilder.java | 78 ++
.../common/clients/kafka/KafkaClient.java | 11 +-
.../kafkaconnect/KafkaConnectEmbedded.java | 10 +
.../services/kafkaconnect/KafkaConnectRunner.java | 9 +
.../kafkaconnect/KafkaConnectRunnerService.java | 6 +
.../services/kafkaconnect/KafkaConnectService.java | 4 +
.../common/test/AbstractTestMessageProducer.java | 59 ++
.../common/test/CamelSinkTestSupport.java | 115 +++
.../common/test/FunctionalTestMessageProducer.java | 7 +
.../common/test/StringMessageProducer.java} | 37 +-
.../common/test/TestMessageProducer.java | 14 +
.../couchbase/sink/CamelSinkCouchbaseITCase.java | 111 ++-
.../sink/CamelSinkElasticSearchITCase.java | 154 ++--
.../file/sink/CamelSinkFileITCase.java | 131 ++-
tests/itests-hdfs/pom.xml | 4 +
.../hdfs/sink/CamelSinkHDFSITCase.java | 102 ++-
.../camel/kafkaconnector/hdfs/services/Dockerfile | 57 --
.../kafkaconnector/hdfs/services/core-site.xml | 27 -
.../kafkaconnector/hdfs/services/hdfs-site.xml | 48 --
.../kafkaconnector/hdfs/services/run-datanode.sh | 19 -
.../kafkaconnector/hdfs/services/run-namenode.sh | 23 -
.../http/sink/CamelSinkHTTPITCase.java | 103 +--
.../jdbc/sink/CamelSinkJDBCITCase.java | 132 +--
.../jdbc/sink/CamelSinkJDBCNoDataSourceITCase.java | 2 -
.../mongodb/sink/CamelSinkMongoDBITCase.java | 79 +-
.../mongodb/source/CamelSourceMongoDBITCase.java | 2 +
.../rabbitmq/sink/RabbitMQSinkITCase.java | 114 ++-
.../kafkaconnector/sjms2/clients/JMSClient.java | 43 +-
...Case.java => CamelSinkIdempotentJMSITCase.java} | 169 ++--
.../sjms2/sink/CamelSinkJMSITCase.java | 122 ++-
...SITCase.java => CamelSinkJMSStartupITCase.java} | 83 +-
.../sjms2/sink/CamelSinkWithDLQJMSITCase.java | 4 -
.../sjms2/source/CamelSourceJMSITCase.java | 2 -
.../slack/sink/CamelSinkSlackITCase.java | 2 -
.../slack/source/CamelSourceSlackITCase.java | 2 -
.../sql/sink/CamelSinkSQLITCase.java | 130 ++-
.../sql/source/CamelSourceSQLITCase.java | 2 -
.../kafkaconnector/ssh/common/SshProperties.java | 11 +
.../ssh/services/SshLocalContainerService.java | 15 +-
.../ssh/services/SshRemoteService.java | 13 +-
.../kafkaconnector/ssh/services/SshService.java | 13 +-
.../ssh/sink/CamelSinkSshITCase.java | 72 +-
.../syslog/sink/CamelSinkSyslogITCase.java | 75 +-
.../syslog/source/CamelSourceSyslogITCase.java | 2 -
.../timer/source/CamelSourceTimerITCase.java | 2 -
.../source/RabbitMQSourcePerformanceITCase.java | 2 -
.../maven/docs/UpdateDocComponentsListMojo.java | 49 +-
.../src/main/resources/nav.mvel | 8 +
.../README.adoc | 4 +
.../maven/AbstractCamelKafkaConnectorMojo.java | 8 +
.../maven/CamelKafkaConnectorDeleteMojo.java | 11 +-
.../maven/GenerateCamelKafkaConnectorsMojo.java | 50 +-
...mel-kafka-connector-fix-dependencies.properties | 2 +
.../camel-kafka-connector-template-pom.template | 2 +-
tooling/pom.xml | 2 +-
322 files changed, 10630 insertions(+), 4643 deletions(-)
create mode 160000 .github/actions/backport
create mode 160000 .github/actions/changelog
create mode 100644 .github/workflows/automatic-changelog-update.yml
create mode 100644 .github/workflows/backport.yml
rename .github/workflows/{rebase-master-onto-camel-master.yml => daily-java-next.yml} (74%)
create mode 100644 .gitmodules
delete mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-paho-mqtt5-sink.json
delete mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-paho-mqtt5-source.json
delete mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-sink.json
delete mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-spring-rabbitmq-source.json
create mode 100644 connectors/camel-aws2-kinesis-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kinesis/transformers/KinesisRecordDataTransforms.java
copy connectors/{camel-cron-kafka-connector => camel-azure-storage-datalake-kafka-connector}/pom.xml (94%)
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/generated/descriptors/connector-source.properties
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/generated/resources/camel-azure-storage-datalake-sink.json
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/generated/resources/camel-azure-storage-datalake-source.json
copy connectors/{camel-zookeeper-master-kafka-connector => camel-azure-storage-datalake-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/main/docs/camel-azure-storage-datalake-kafka-sink-connector.adoc
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/main/docs/camel-azure-storage-datalake-kafka-source-connector.adoc
copy archetypes/camel-kafka-connector-extensible-archetype/src/test/resources/projects/camel-timer-kafka-connector/archetype.properties => connectors/camel-azure-storage-datalake-kafka-connector/src/main/docs/examples/CamelAzurestoragedatalakeSinkConnector.properties (64%)
copy archetypes/camel-kafka-connector-extensible-archetype/src/test/resources/projects/camel-timer-kafka-connector/archetype.properties => connectors/camel-azure-storage-datalake-kafka-connector/src/main/docs/examples/CamelAzurestoragedatalakeSourceConnector.properties (64%)
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java => connectors/camel-azure-storage-datalake-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalake/CamelAzurestoragedatalakeSinkConnector.java (54%)
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalake/CamelAzurestoragedatalakeSinkConnectorConfig.java
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalake/CamelAzurestoragedatalakeSinkTask.java
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java => connectors/camel-azure-storage-datalake-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalake/CamelAzurestoragedatalakeSourceConnector.java (54%)
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalake/CamelAzurestoragedatalakeSourceConnectorConfig.java
create mode 100644 connectors/camel-azure-storage-datalake-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/azurestoragedatalake/CamelAzurestoragedatalakeSourceTask.java
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-azure-storage-datalake-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-azure-storage-datalake-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%)
copy connectors/{camel-cron-kafka-connector => camel-hwcloud-smn-kafka-connector}/pom.xml (95%)
create mode 100644 connectors/camel-hwcloud-smn-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644 connectors/camel-hwcloud-smn-kafka-connector/src/generated/resources/camel-hwcloud-smn-sink.json
copy connectors/{camel-zookeeper-master-kafka-connector => camel-hwcloud-smn-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644 connectors/camel-hwcloud-smn-kafka-connector/src/main/docs/camel-hwcloud-smn-kafka-sink-connector.adoc
copy tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-fix-dependencies.properties => connectors/camel-hwcloud-smn-kafka-connector/src/main/docs/examples/CamelHwcloudsmnSinkConnector.properties (53%)
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java => connectors/camel-hwcloud-smn-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudsmn/CamelHwcloudsmnSinkConnector.java (56%)
create mode 100644 connectors/camel-hwcloud-smn-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudsmn/CamelHwcloudsmnSinkConnectorConfig.java
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java => connectors/camel-hwcloud-smn-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudsmn/CamelHwcloudsmnSinkTask.java (50%)
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-hwcloud-smn-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-hwcloud-smn-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%)
copy connectors/{camel-cron-kafka-connector => camel-infinispan-embedded-kafka-connector}/pom.xml (94%)
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/generated/descriptors/connector-source.properties
copy connectors/{camel-infinispan-kafka-connector/src/generated/resources/camel-infinispan-sink.json => camel-infinispan-embedded-kafka-connector/src/generated/resources/camel-infinispan-embedded-sink.json} (52%)
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/generated/resources/camel-infinispan-embedded-source.json
copy connectors/{camel-zookeeper-master-kafka-connector => camel-infinispan-embedded-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/main/docs/camel-infinispan-embedded-kafka-sink-connector.adoc
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/main/docs/camel-infinispan-embedded-kafka-source-connector.adoc
copy tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-fix-dependencies.properties => connectors/camel-infinispan-embedded-kafka-connector/src/main/docs/examples/CamelInfinispanembeddedSinkConnector.properties (57%)
copy tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-fix-dependencies.properties => connectors/camel-infinispan-embedded-kafka-connector/src/main/docs/examples/CamelInfinispanembeddedSourceConnector.properties (57%)
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java => connectors/camel-infinispan-embedded-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispanembedded/CamelInfinispanembeddedSinkConnector.java (55%)
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispanembedded/CamelInfinispanembeddedSinkConnectorConfig.java
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispanembedded/CamelInfinispanembeddedSinkTask.java
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java => connectors/camel-infinispan-embedded-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispanembedded/CamelInfinispanembeddedSourceConnector.java (54%)
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispanembedded/CamelInfinispanembeddedSourceConnectorConfig.java
create mode 100644 connectors/camel-infinispan-embedded-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/infinispanembedded/CamelInfinispanembeddedSourceTask.java
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-infinispan-embedded-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-infinispan-embedded-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%)
copy connectors/{camel-kafka-connecotr-java-header.txt => camel-kafka-connector-java-header.txt} (100%)
copy connectors/{camel-cron-kafka-connector => camel-kamelet-kafka-connector}/pom.xml (95%)
create mode 100644 connectors/camel-kamelet-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644 connectors/camel-kamelet-kafka-connector/src/generated/descriptors/connector-source.properties
copy connectors/{camel-direct-kafka-connector/src/generated/resources/camel-direct-sink.json => camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json} (65%)
copy camel-kafka-connector-catalog/src/generated/resources/connectors/camel-direct-source.json => connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json (66%)
copy connectors/{camel-zookeeper-master-kafka-connector => camel-kamelet-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644 connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc
create mode 100644 connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc
copy archetypes/camel-kafka-connector-extensible-archetype/src/test/resources/projects/camel-timer-kafka-connector/archetype.properties => connectors/camel-kamelet-kafka-connector/src/main/docs/examples/CamelKameletSinkConnector.properties (64%)
copy archetypes/camel-kafka-connector-extensible-archetype/src/test/resources/projects/camel-timer-kafka-connector/archetype.properties => connectors/camel-kamelet-kafka-connector/src/main/docs/examples/CamelKameletSourceConnector.properties (63%)
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java => connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSinkConnector.java (57%)
create mode 100644 connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSinkConnectorConfig.java
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java => connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSinkTask.java (50%)
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java => connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSourceConnector.java (56%)
create mode 100644 connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSourceConnectorConfig.java
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java => connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSourceTask.java (50%)
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-kamelet-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-kamelet-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%)
copy connectors/{camel-cron-kafka-connector => camel-stitch-kafka-connector}/pom.xml (95%)
create mode 100644 connectors/camel-stitch-kafka-connector/src/generated/descriptors/connector-sink.properties
create mode 100644 connectors/camel-stitch-kafka-connector/src/generated/resources/camel-stitch-sink.json
copy connectors/{camel-zookeeper-master-kafka-connector => camel-stitch-kafka-connector}/src/main/assembly/package.xml (100%)
create mode 100644 connectors/camel-stitch-kafka-connector/src/main/docs/camel-stitch-kafka-sink-connector.adoc
copy archetypes/camel-kafka-connector-extensible-archetype/src/test/resources/projects/camel-timer-kafka-connector/archetype.properties => connectors/camel-stitch-kafka-connector/src/main/docs/examples/CamelStitchSinkConnector.properties (60%)
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshRemoteService.java => connectors/camel-stitch-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/stitch/CamelStitchSinkConnector.java (57%)
create mode 100644 connectors/camel-stitch-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/stitch/CamelStitchSinkConnectorConfig.java
copy tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java => connectors/camel-stitch-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/stitch/CamelStitchSinkTask.java (50%)
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-stitch-kafka-connector}/src/main/resources/META-INF/LICENSE.txt (100%)
copy {tooling/camel-kafka-connector-docs-maven-plugin => connectors/camel-stitch-kafka-connector}/src/main/resources/META-INF/NOTICE.txt (100%)
create mode 100644 core/src/main/java/org/apache/camel/kafkaconnector/transforms/FieldsToHeadersTransform.java
create mode 100644 core/src/main/java/org/apache/camel/kafkaconnector/transforms/SchemaAndStructToJsonTransform.java
create mode 100644 core/src/test/java/org/apache/camel/kafkaconnector/transforms/FieldsToHeadersTransformTest.java
copy core/src/test/java/org/apache/camel/kafkaconnector/transforms/{SinkPojoToSchemaAndStructTransformTest.java => SchemaAndStructToJsonTransformTest.java} (62%)
create mode 100644 docs/modules/ROOT/pages/connectors/camel-azure-storage-datalake-kafka-sink-connector.adoc
create mode 100644 docs/modules/ROOT/pages/connectors/camel-azure-storage-datalake-kafka-source-connector.adoc
create mode 100644 docs/modules/ROOT/pages/connectors/camel-hwcloud-smn-kafka-sink-connector.adoc
create mode 100644 docs/modules/ROOT/pages/connectors/camel-infinispan-embedded-kafka-sink-connector.adoc
create mode 100644 docs/modules/ROOT/pages/connectors/camel-infinispan-embedded-kafka-source-connector.adoc
create mode 100644 docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc
create mode 100644 docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc
create mode 100644 docs/modules/ROOT/pages/connectors/camel-stitch-kafka-sink-connector.adoc
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/AWSPropertiesUtils.java
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelAWSCWPropertyFactory.java
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/cw/sink/CamelSinkAWSCWITCase.java
copy tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/{kinesis/source/TestKinesisConfiguration.java => cw/sink/TestCloudWatchConfiguration.java} (64%)
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/ec2/sink/CamelAWSEC2PropertyFactory.java
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/ec2/sink/CamelSinkAWSEC2ITCase.java
copy tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/{kinesis/source/TestKinesisConfiguration.java => ec2/sink/TestEC2Configuration.java} (64%)
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/iam/sink/CamelAWSIAMPropertyFactory.java
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/iam/sink/CamelSinkAWSIAMITCase.java
copy tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/{kinesis/source/TestKinesisConfiguration.java => iam/sink/TestIAMConfiguration.java} (64%)
copy tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/{source/CamelSourceAWSKinesisITCase.java => common/KinesisUtils.java} (55%)
copy tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/{source => common}/TestKinesisConfiguration.java (95%)
copy tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/{source => sink}/CamelAWSKinesisPropertyFactory.java (67%)
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/sink/CamelSinkAWSKinesisITCase.java
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kms/sink/CamelAWSKMSPropertyFactory.java
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kms/sink/CamelSinkAWSKMSITCase.java
rename tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/{kinesis/source/TestKinesisConfiguration.java => kms/sink/TestKMS2Configuration.java} (64%)
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/common/S3Utils.java
rename tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/{source => common}/TestS3Configuration.java (95%)
copy tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/{source => sink}/CamelAWSS3PropertyFactory.java (56%)
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/sink/CamelSinkAWSS3ITCase.java
rename tests/itests-azure-storage-queue/src/test/java/org/apache/camel/kafkaconnector/azure/storage/queue/{sink => common}/TestQueueConfiguration.java (95%)
copy tests/itests-azure-storage-queue/src/test/java/org/apache/camel/kafkaconnector/azure/storage/queue/{sink/CamelSinkAzureStorageQueueITCase.java => source/CamelSourceAzureStorageQueueITCase.java} (56%)
create mode 100644 tests/itests-azure-storage-queue/src/test/java/org/apache/camel/kafkaconnector/azure/storage/queue/source/CamelSourceAzureStorageQueuePropertyFactory.java
create mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/IdempotencyConfigBuilder.java
create mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/AbstractTestMessageProducer.java
create mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSinkTestSupport.java
copy connectors/camel-kafka-connecotr-java-header.txt => tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/FunctionalTestMessageProducer.java (83%)
copy tests/{itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/services/SshLocalContainerService.java => itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/StringMessageProducer.java} (51%)
copy connectors/camel-kafka-connecotr-java-header.txt => tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/TestMessageProducer.java (67%)
delete mode 100644 tests/itests-hdfs/src/test/resources/org/apache/camel/kafkaconnector/hdfs/services/Dockerfile
delete mode 100644 tests/itests-hdfs/src/test/resources/org/apache/camel/kafkaconnector/hdfs/services/core-site.xml
delete mode 100644 tests/itests-hdfs/src/test/resources/org/apache/camel/kafkaconnector/hdfs/services/hdfs-site.xml
delete mode 100755 tests/itests-hdfs/src/test/resources/org/apache/camel/kafkaconnector/hdfs/services/run-datanode.sh
delete mode 100755 tests/itests-hdfs/src/test/resources/org/apache/camel/kafkaconnector/hdfs/services/run-namenode.sh
copy tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/{CamelSinkJMSITCase.java => CamelSinkIdempotentJMSITCase.java} (56%)
copy tests/itests-sjms2/src/test/java/org/apache/camel/kafkaconnector/sjms2/sink/{CamelSinkWithDLQJMSITCase.java => CamelSinkJMSStartupITCase.java} (62%)
rename connectors/camel-kafka-connecotr-java-header.txt => tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/common/SshProperties.java (77%)
create mode 100644 tooling/camel-kafka-connector-docs-maven-plugin/src/main/resources/nav.mvel