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/12/09 07:41:56 UTC
[camel-kafka-connector] 16/17: Fixed build and regen
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit a68e9b6be313c4b25bc16d2b3e10b45d9ae55e07
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Dec 9 08:18:34 2020 +0100
Fixed build and regen
---
.../aws/v1/kinesis/source/CamelSourceAWSKinesisITCase.java | 4 +---
.../camel/kafkaconnector/aws/v1/s3/source/CamelSourceAWSS3ITCase.java | 1 -
2 files changed, 1 insertion(+), 4 deletions(-)
diff --git a/tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/kinesis/source/CamelSourceAWSKinesisITCase.java b/tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/kinesis/source/CamelSourceAWSKinesisITCase.java
index f9042be..da6ab70 100644
--- a/tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/kinesis/source/CamelSourceAWSKinesisITCase.java
+++ b/tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/kinesis/source/CamelSourceAWSKinesisITCase.java
@@ -60,11 +60,9 @@ import static org.junit.jupiter.api.Assertions.fail;
public class CamelSourceAWSKinesisITCase extends AbstractKafkaTest {
@RegisterExtension
+ public static AWSService service = AWSServiceFactory.createKinesisService();
private static final Logger LOG = LoggerFactory.getLogger(CamelSourceAWSKinesisITCase.class);
- @RegisterExtension
- AWSService<AmazonKinesis> service = AWSServiceFactory.createKinesisService();
-
private String streamName;
private AmazonKinesis awsKinesisClient;
private volatile int received;
diff --git a/tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/s3/source/CamelSourceAWSS3ITCase.java b/tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/s3/source/CamelSourceAWSS3ITCase.java
index 8d11701..87fa9ad 100644
--- a/tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/s3/source/CamelSourceAWSS3ITCase.java
+++ b/tests/itests-aws-v1/src/test/java/org/apache/camel/kafkaconnector/aws/v1/s3/source/CamelSourceAWSS3ITCase.java
@@ -55,7 +55,6 @@ import static org.junit.jupiter.api.Assertions.fail;
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@EnabledIfSystemProperty(named = "enable.slow.tests", matches = "true")
public class CamelSourceAWSS3ITCase extends AbstractKafkaTest {
- private static final Logger LOG = LoggerFactory.getLogger(CamelSourceAWSS3ITCase.class);
@RegisterExtension
public static AWSService service = AWSServiceFactory.createS3Service();