You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2020/10/24 01:35:00 UTC
[camel-kafka-connector] branch camel-master updated (40003aa ->
39e8b73)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 40003aa Early Strimzi Test: Lets test wit 0.20.0 RC3
add de49dbb Updated CHANGELOG.md
add 644a52d Switches the Kafka test infra-structure
add ea73c5f Switches the AWS v1 test infra-structure
add 3bc6b99 Decouple the Cassandra client from the service to simplify moving the services to Camel core
add 39e8b73 Switches the AWS v2 test infra-structure
No new revisions were added by this update.
Summary of changes:
CHANGELOG.md | 12 +-
tests/itests-aws-v1/pom.xml | 20 +--
.../aws/v1/clients/AWSClientUtils.java | 146 +--------------------
.../aws/v1/clients/AWSSQSClient.java | 15 +--
.../aws/v1/common/TestAWSCredentialsProvider.java | 69 ----------
.../source/CamelAWSKinesisPropertyFactory.java | 19 +--
.../source/CamelSourceAWSKinesisITCase.java | 43 +++---
.../kinesis/source/TestKinesisConfiguration.java | 3 +-
.../v1/s3/source/CamelAWSS3PropertyFactory.java | 16 +--
.../aws/v1/s3/source/CamelSourceAWSS3ITCase.java | 47 +++----
.../aws/v1/s3/source/TestS3Configuration.java | 3 +-
.../services/AWSKinesisLocalContainerService.java | 57 --------
.../aws/v1/services/AWSLocalContainerService.java | 104 ---------------
.../aws/v1/services/AWSRemoteService.java | 70 ----------
.../v1/services/AWSS3LocalContainerService.java | 57 --------
.../v1/services/AWSSNSLocalContainerService.java | 53 --------
.../v1/services/AWSSQSLocalContainerService.java | 51 -------
.../aws/v1/services/AWSServiceFactory.java | 107 ---------------
.../v1/sns/sink/CamelAWSSNSPropertyFactory.java | 23 ++--
.../aws/v1/sns/sink/CamelSinkAWSSNSITCase.java | 45 +++----
.../aws/v1/sns/sink/TestSNSConfiguration.java | 2 +-
.../v1/sqs/sink/CamelAWSSQSPropertyFactory.java | 20 +--
.../aws/v1/sqs/sink/CamelSinkAWSSQSITCase.java | 49 +++----
.../v1/sqs/source/CamelAWSSQSPropertyFactory.java | 15 +--
.../aws/v1/sqs/source/CamelSourceAWSSQSITCase.java | 32 ++---
tests/itests-aws-v2/pom.xml | 14 +-
.../aws/v2/clients/AWSSDKClientUtils.java | 108 ---------------
.../aws/v2/common/TestAWSCredentialsProvider.java | 70 ----------
.../source/CamelAWSKinesisPropertyFactory.java | 2 +-
.../source/CamelSourceAWSKinesisITCase.java | 6 +-
.../kinesis/source/TestKinesisConfiguration.java | 2 +-
.../v2/s3/source/CamelAWSS3PropertyFactory.java | 2 +-
.../aws/v2/s3/source/CamelSourceAWSS3ITCase.java | 8 +-
.../aws/v2/s3/source/TestS3Configuration.java | 2 +-
.../aws/v2/services/AWSContainer.java | 79 -----------
.../services/AWSKinesisLocalContainerService.java | 47 -------
.../aws/v2/services/AWSLocalContainerService.java | 94 -------------
.../aws/v2/services/AWSRemoteService.java | 67 ----------
.../v2/services/AWSS3LocalContainerService.java | 47 -------
.../v2/services/AWSSQSLocalContainerService.java | 48 -------
.../aws/v2/services/AWSServiceFactory.java | 95 --------------
.../kafkaconnector/aws/v2/services/Service.java | 38 ------
.../v2/sqs/sink/CamelAWSSQSPropertyFactory.java | 2 +-
.../aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java | 8 +-
.../v2/sqs/source/CamelAWSSQSPropertyFactory.java | 2 +-
.../aws/v2/sqs/source/CamelSourceAWSSQSITCase.java | 8 +-
.../services/CassandraLocalContainerService.java | 9 --
.../cassandra/services/CassandraService.java | 4 -
.../cassandra/services/RemoteCassandraService.java | 10 --
.../cassandra/sink/CamelSinkCassandraITCase.java | 4 +-
.../source/CamelSourceCassandraITCase.java | 4 +-
.../kafkaconnector/common/AbstractKafkaTest.java | 2 +-
.../services/kafka/ContainerLocalKafkaService.java | 43 ------
.../services/kafka/EmbeddedKafkaService.java | 1 +
.../common/services/kafka/KafkaService.java | 68 ----------
.../common/services/kafka/KafkaServiceFactory.java | 17 +--
.../common/services/kafka/RemoteKafkaService.java | 40 ------
.../common/services/kafka/StrimziContainer.java | 66 ----------
.../common/services/kafka/StrimziService.java | 109 ---------------
.../common/services/kafka/ZookeeperContainer.java | 53 --------
.../kafkaconnect/KafkaConnectEmbedded.java | 2 +-
.../kafkaconnect/KafkaConnectRunnerFactory.java | 2 +-
.../kafkaconnect/KafkaConnectRunnerService.java | 2 +-
tests/itests-parent/pom.xml | 8 ++
64 files changed, 199 insertions(+), 2072 deletions(-)
delete mode 100644 tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/common/TestAWSCredentialsProvider.java
delete mode 100644 tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/services/AWSKinesisLocalContainerService.java
delete mode 100644 tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/services/AWSLocalContainerService.java
delete mode 100644 tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/services/AWSRemoteService.java
delete mode 100644 tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/services/AWSS3LocalContainerService.java
delete mode 100644 tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/services/AWSSNSLocalContainerService.java
delete mode 100644 tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/services/AWSSQSLocalContainerService.java
delete mode 100644 tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/services/AWSServiceFactory.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/common/TestAWSCredentialsProvider.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSContainer.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSKinesisLocalContainerService.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSLocalContainerService.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSRemoteService.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSS3LocalContainerService.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSSQSLocalContainerService.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/AWSServiceFactory.java
delete mode 100644 tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/services/Service.java
delete mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/ContainerLocalKafkaService.java
delete mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/KafkaService.java
delete mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/RemoteKafkaService.java
delete mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/StrimziContainer.java
delete mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/StrimziService.java
delete mode 100644 tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafka/ZookeeperContainer.java