You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/01/29 18:35:04 UTC
[camel-kafka-connector] branch camel-master updated (a50dd04 ->
5a3f522)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from a50dd04 [create-pull-request] automated change
new 62d42d8 Updates SSH tests to Camel's 3.7 test infra interfaces
new 46f4a92 Added SchemaAndStructToJsonTransform fix #843
new 8fd39b6 Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest
new 83ca09e Added a test to make sure we retain original exception data on errors
new 276c648 (chores) Cleanup topic deletion code and allow public access to the admin client
new 8889023 Ensures that Couchbase client dependencies are packed with the connector (GH issue #878)
new 2b9243f Bump to Kafka 2.7.0
new 1c56bcc Upgrade Scala Library to version 2.12.12
new 951c764 Mark HDFS Integration test as slow
new e9d13f3 Fixed imports
new 6b05565 Fixed checkstyle
new e481192 AWS2-Kinesis connector: Add a transformation to extract only the data from a source stream
new 7d26527 Regen documentation
new a91a24b Fixed CS
new ba4b687 Modify the Github Actions configuration to allow archiving test logs (#882)
new 9956727 Upgrade Strimzi to version 0.21.0.kafka-2.7.0
new 2e33e3e Always run the archiving step so we can have log files on failure and cancelled
new eedea24 Fix using an incorrect format for the continuity check logic
new 0270002 Bump Apicurio Registry to version 1.3.2.Final
new 6477962 Fix HDFS compatibility issues with Jetty deps on camel-hdfs
new a97b7a8 Move HDFS tests to the default set after fixing the HDFS test incompatibilities
new 35001f5 Compatibility matrix: added ckc 0.7.0
new c807f18 Bump Strimzi to version 0.21.1
new 9ec8178 Add a column to compatibility matrix about Kafka version
new a3db961 Fixed version in compatibility matrix for 0.6.1
new 25468bf Removed unused HDFS test files that were migrated to camel-test-infra
new ad1f366 (chores) Cleanup unused annotations
new 55772ba Strimzi project is now using Quay for their images
new 474e0bc Added new daily JDK 14 build on github actions
new 74f95d3 Camel-Cron connector: We need to add at least camel-quartz as dependency
new 71336f1 Created a base test class for AWS sink tests
new dfc21cd Simplified handling of setting common AWS 2 properties
new 63df099 Added new integration test for AWS 2 Cloud Watch
new e241f0b (chores) fixed typo in AWS v2 Cloud Watch test
new dc1e909 Added new integration test for AWS 2 EC2
new b38d63b Added AWS v2 IAM sink test case
new cd538de Prevent matrix jobs from rewriting the archived log on github actions
new e369b72 Fix link in idempotency.adoc
new 5ebe2af Added AWS v2 Kinesis sink test case
new c3c9098 Fix table doc and rename connecotr word
new a3931a2 Java 14: upgrade plugins to versions that support Java 14
new fd2061e Java 14: update the connector version used in test to one that supports Java 14
new 1c72b30 Java 14: update the mvel2 version to one that supports Java 14
new a5961b7 Java 14: re-order archetypes module to avoid a cyclic dependency between modules
new d3c5135 Use an assembly plugin version that is supported by java 14
new fa0fe7f Java 14: bump Groovy version to the same one used in Camel
new 467904a Java 14: added the new supported Java version to the build matrix
new ffcbda2 Removes the daily JDK 14 github action because it is already being run on the default CI action
new 3363fcd Added a daily workflow for building with newer Java versions (#928)
new ec74546 Add a map Camel Properties to Kafka headers option to make the behavior configurable
new c2c6644 Fixed CS
new cc79069 Added AWS v2 KMS sink test case
new eb52502 Added AWS v2 S3 sink test case
new 3456a21 Upgrade docs to 0.7.1 as latest release
new 2c77a0e Regen
new aa9aad7 Upgrade archetype instructions to version 0.8.0
new 36cc5b9 create a toHeader SMT #902
new c661095 Add a map Camel Headers to Kafka headers option to make the behavior configurable
new 7dd9512 Fixed CS
new d3b4cf4 Added Azure Storage Queue source test case
new d690e85 Regen documentation
new 5a3f522 Update docs
The 62 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/automatic-sync-camel-master.yml | 6 +
.github/workflows/ci-build.yml | 8 +-
.../{ci-build.yml => daily-java-next.yml} | 25 +-
.../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 +
.../camel-azure-storage-datalake-sink.json | 416 ++++++++++++
.../camel-azure-storage-datalake-source.json | 411 ++++++++++++
.../resources/connectors/camel-direct-sink.json | 7 +
.../resources/connectors/camel-direct-source.json | 7 +
.../connectors/camel-hwcloud-smn-sink.json | 114 ++++
.../connectors/camel-infinispan-embedded-sink.json | 182 ++----
.../camel-infinispan-embedded-source.json | 199 ++++++
.../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 +
.../resources/connectors/camel-kamelet-sink.json | 54 +-
...irect-source.json => camel-kamelet-source.json} | 42 +-
.../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 +
.../resources/connectors/camel-sql-sink.json | 2 +-
.../resources/connectors/camel-sql-source.json | 2 +-
.../resources/connectors/camel-stitch-sink.json | 140 ++++
.../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 +
.../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 | 42 +-
.../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 | 42 +-
.../kamelet/CamelKameletSourceConnector.java | 38 +-
.../kamelet/CamelKameletSourceConnectorConfig.java | 80 +++
.../kamelet/CamelKameletSourceTask.java | 42 +-
.../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 +
.../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 | 42 +-
.../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 +-
.../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 +-
...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 +-
.../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 +-
tests/itests-aws-v2/pom.xml | 20 +
.../aws/v2/common/AWSPropertiesUtils.java | 63 ++
.../aws/v2/common/CamelSinkAWSTestSupport.java | 90 +++
.../aws/v2/cw/sink/CamelAWSCWPropertyFactory.java | 73 +++
.../aws/v2/cw/sink/CamelSinkAWSCWITCase.java | 156 +++++
.../sink/TestCloudWatchConfiguration.java} | 18 +-
.../v2/ec2/sink/CamelAWSEC2PropertyFactory.java | 73 +++
.../aws/v2/ec2/sink/CamelSinkAWSEC2ITCase.java | 150 +++++
.../sink/TestEC2Configuration.java} | 18 +-
.../v2/iam/sink/CamelAWSIAMPropertyFactory.java | 73 +++
.../aws/v2/iam/sink/CamelSinkAWSIAMITCase.java | 140 ++++
.../sink/TestIAMConfiguration.java} | 18 +-
.../KinesisUtils.java} | 167 ++---
.../TestKinesisConfiguration.java | 2 +-
.../CamelAWSKinesisPropertyFactory.java | 32 +-
.../v2/kinesis/sink/CamelSinkAWSKinesisITCase.java | 148 +++++
.../source/CamelAWSKinesisPropertyFactory.java | 15 +-
.../source/CamelSourceAWSKinesisITCase.java | 164 +----
.../v2/kms/sink/CamelAWSKMSPropertyFactory.java | 73 +++
.../aws/v2/kms/sink/CamelSinkAWSKMSITCase.java | 151 +++++
.../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 | 152 +++++
.../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 | 77 +--
.../v2/sqs/source/CamelAWSSQSPropertyFactory.java | 25 +-
.../{sink => common}/TestQueueConfiguration.java | 2 +-
.../sink/CamelSinkAzureStorageQueueITCase.java | 1 +
.../CamelSourceAzureStorageQueueITCase.java} | 96 +--
...amelSourceAzureStorageQueuePropertyFactory.java | 52 ++
.../common/BasicConnectorPropertyFactory.java | 2 +-
.../common/clients/kafka/KafkaClient.java | 11 +-
.../kafkaconnect/KafkaConnectEmbedded.java | 10 +
.../services/kafkaconnect/KafkaConnectRunner.java | 9 +
.../kafkaconnect/KafkaConnectRunnerService.java | 6 +
.../services/kafkaconnect/KafkaConnectService.java | 4 +
tests/itests-hdfs/pom.xml | 4 +
.../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 | 2 -
.../jdbc/sink/CamelSinkJDBCITCase.java | 2 -
.../jdbc/sink/CamelSinkJDBCNoDataSourceITCase.java | 2 -
.../sjms2/sink/CamelSinkJMSITCase.java | 2 -
...SITCase.java => CamelSinkJMSStartupITCase.java} | 81 +--
.../sjms2/sink/CamelSinkWithDLQJMSITCase.java | 2 -
.../sjms2/source/CamelSourceJMSITCase.java | 2 -
.../slack/sink/CamelSinkSlackITCase.java | 2 -
.../slack/source/CamelSourceSlackITCase.java | 2 -
.../sql/sink/CamelSinkSQLITCase.java | 2 -
.../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 | 2 -
.../syslog/sink/CamelSinkSyslogITCase.java | 2 -
.../syslog/source/CamelSourceSyslogITCase.java | 2 -
.../timer/source/CamelSourceTimerITCase.java | 2 -
.../source/RabbitMQSourcePerformanceITCase.java | 2 -
.../README.adoc | 4 +
...mel-kafka-connector-fix-dependencies.properties | 2 +
.../camel-kafka-connector-template-pom.template | 2 +-
tooling/pom.xml | 2 +-
284 files changed, 9663 insertions(+), 2369 deletions(-)
copy .github/workflows/{ci-build.yml => daily-java-next.yml} (88%)
create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-datalake-sink.json
create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-azure-storage-datalake-source.json
create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-smn-sink.json
copy connectors/camel-infinispan-kafka-connector/src/generated/resources/camel-infinispan-sink.json => camel-kafka-connector-catalog/src/generated/resources/connectors/camel-infinispan-embedded-sink.json (52%)
create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-infinispan-embedded-source.json
copy connectors/camel-direct-kafka-connector/src/generated/resources/camel-direct-sink.json => camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json (65%)
copy camel-kafka-connector-catalog/src/generated/resources/connectors/{camel-direct-source.json => camel-kamelet-source.json} (66%)
create mode 100644 camel-kafka-connector-catalog/src/generated/resources/connectors/camel-stitch-sink.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/SshRemoteService.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/SshRemoteService.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/SshRemoteService.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/SshRemoteService.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/common/CamelSinkAWSTestSupport.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
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/{CamelSinkWithDLQJMSITCase.java => CamelSinkJMSStartupITCase.java} (64%)
rename connectors/camel-kafka-connecotr-java-header.txt => tests/itests-ssh/src/test/java/org/apache/camel/kafkaconnector/ssh/common/SshProperties.java (77%)