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%)
