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 2020/08/05 10:16:56 UTC
[camel-kafka-connector] branch master updated (4a73d04 -> 438cdb8)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 4a73d04 Merge pull request #357 from apache/strimzi-up
new 309ac65 Remove the AWSCredentials from the public interface to allow reusing common code
new afd890a Move the AWSService interface to the reusable AWS common test component
new c82c7c2 AWS SDK v2 integration tests for AWS Kinesis
new 56364b7 Renamed package in the AWS SDK v1 tests to match the AWS SDK version
new 438cdb8 Merge pull request #358 from orpiske/aws2-kinesis
The 622 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:
tests/{itests-aws => itests-aws-common}/pom.xml | 48 ++---
.../kafkaconnector/aws/common/AWSConfigs.java | 1 -
.../aws/common}/services/AWSService.java | 5 +-
tests/{itests-aws => itests-aws-v1}/pom.xml | 12 +-
.../aws/v1}/clients/AWSClientUtils.java | 4 +-
.../aws/v1}/clients/AWSSQSClient.java | 2 +-
.../kafkaconnector/aws/v1}/common/AWSCommon.java | 2 +-
.../aws/v1}/common/TestAWSCredentialsProvider.java | 3 +-
.../source/CamelAWSKinesisPropertyFactory.java | 2 +-
.../source/CamelSourceAWSKinesisITCase.java | 6 +-
.../kinesis/source/TestKinesisConfiguration.java | 4 +-
.../v1}/s3/source/CamelAWSS3PropertyFactory.java | 2 +-
.../aws/v1}/s3/source/CamelSourceAWSS3ITCase.java | 8 +-
.../aws/v1}/s3/source/TestS3Configuration.java | 4 +-
.../services/AWSKinesisLocalContainerService.java | 2 +-
.../aws/v1}/services/AWSLocalContainerService.java | 6 +-
.../aws/v1}/services/AWSRemoteService.java | 12 +-
.../v1}/services/AWSS3LocalContainerService.java | 2 +-
.../v1}/services/AWSSNSLocalContainerService.java | 4 +-
.../v1}/services/AWSSQSLocalContainerService.java | 4 +-
.../aws/v1}/services/AWSServiceFactory.java | 7 +-
.../v1}/sns/sink/CamelAWSSNSPropertyFactory.java | 2 +-
.../aws/v1}/sns/sink/CamelSinkAWSSNSITCase.java | 10 +-
.../aws/v1}/sns/sink/TestSNSConfiguration.java | 4 +-
.../v1}/sqs/sink/CamelAWSSQSPropertyFactory.java | 2 +-
.../aws/v1}/sqs/sink/CamelSinkAWSSQSITCase.java | 10 +-
.../v1}/sqs/source/CamelAWSSQSPropertyFactory.java | 2 +-
.../v1}/sqs/source/CamelSourceAWSSQSITCase.java | 10 +-
.../kafkaconnector/aws/v1}/s3/source/file0.test | 0
.../kafkaconnector/aws/v1}/s3/source/file1.test | 0
.../kafkaconnector/aws/v1}/s3/source/file2.test | 0
.../kafkaconnector/aws/v1}/s3/source/file3.test | 0
.../kafkaconnector/aws/v1}/s3/source/file4.test | 0
.../kafkaconnector/aws/v1}/s3/source/file5.test | 0
.../kafkaconnector/aws/v1}/s3/source/file6.test | 0
.../kafkaconnector/aws/v1}/s3/source/file7.test | 0
.../kafkaconnector/aws/v1}/s3/source/file8.test | 0
.../kafkaconnector/aws/v1}/s3/source/file9.test | 0
tests/{itests-aws => itests-aws-v2}/pom.xml | 35 ++-
.../aws/v2/clients/AWSSDKClientUtils.java | 84 ++++++++
.../aws/v2}/common/TestAWSCredentialsProvider.java | 30 +--
.../source/CamelAWSKinesisPropertyFactory.java | 24 +--
.../source/CamelSourceAWSKinesisITCase.java | 238 ++++++++++++---------
.../kinesis/source/TestKinesisConfiguration.java} | 25 +--
.../aws/v2/services/AWSContainer.java | 76 +++++++
.../services/AWSKinesisLocalContainerService.java | 47 ++++
.../aws/v2}/services/AWSLocalContainerService.java | 66 +++---
.../aws/v2}/services/AWSRemoteService.java | 38 ++--
.../aws/v2/services/AWSServiceFactory.java | 58 +++++
.../kafkaconnector/aws/v2/services/Service.java} | 24 ++-
tests/pom.xml | 4 +-
51 files changed, 588 insertions(+), 341 deletions(-)
copy tests/{itests-aws => itests-aws-common}/pom.xml (51%)
copy tests/{itests-aws => itests-aws-common}/src/test/java/org/apache/camel/kafkaconnector/aws/common/AWSConfigs.java (93%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-common/src/test/java/org/apache/camel/kafkaconnector/aws/common}/services/AWSService.java (92%)
copy tests/{itests-aws => itests-aws-v1}/pom.xml (88%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/clients/AWSClientUtils.java (98%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/clients/AWSSQSClient.java (98%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/common/AWSCommon.java (98%)
copy tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/common/TestAWSCredentialsProvider.java (94%)
copy tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/kinesis/source/CamelAWSKinesisPropertyFactory.java (98%)
copy tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/kinesis/source/CamelSourceAWSKinesisITCase.java (98%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/kinesis/source/TestKinesisConfiguration.java (90%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/s3/source/CamelAWSS3PropertyFactory.java (98%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/s3/source/CamelSourceAWSS3ITCase.java (96%)
copy tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/s3/source/TestS3Configuration.java (90%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/services/AWSKinesisLocalContainerService.java (97%)
copy tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/services/AWSLocalContainerService.java (95%)
copy tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/services/AWSRemoteService.java (85%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/services/AWSS3LocalContainerService.java (97%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/services/AWSSNSLocalContainerService.java (93%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/services/AWSSQSLocalContainerService.java (93%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/services/AWSServiceFactory.java (94%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/sns/sink/CamelAWSSNSPropertyFactory.java (98%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/sns/sink/CamelSinkAWSSNSITCase.java (96%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/sns/sink/TestSNSConfiguration.java (90%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/sqs/sink/CamelAWSSQSPropertyFactory.java (98%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/sqs/sink/CamelSinkAWSSQSITCase.java (96%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/sqs/source/CamelAWSSQSPropertyFactory.java (98%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1}/sqs/source/CamelSourceAWSSQSITCase.java (94%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file0.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file1.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file2.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file3.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file4.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file5.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file6.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file7.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file8.test (100%)
rename tests/{itests-aws/src/test/resources/org/apache/camel/kafkaconnector/aws => itests-aws-v1/src/test/resources/org/apache/camel/kafkaconnector/aws/v1}/s3/source/file9.test (100%)
rename tests/{itests-aws => itests-aws-v2}/pom.xml (68%)
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/clients/AWSSDKClientUtils.java
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2}/common/TestAWSCredentialsProvider.java (66%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2}/kinesis/source/CamelAWSKinesisPropertyFactory.java (87%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2}/kinesis/source/CamelSourceAWSKinesisITCase.java (64%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/s3/source/TestS3Configuration.java => itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/source/TestKinesisConfiguration.java} (59%)
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSContainer.java
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSKinesisLocalContainerService.java
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2}/services/AWSLocalContainerService.java (59%)
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws => itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2}/services/AWSRemoteService.java (59%)
create mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSServiceFactory.java
rename tests/{itests-aws/src/test/java/org/apache/camel/kafkaconnector/aws/common/AWSConfigs.java => itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/Service.java} (62%)