[camel-kafka-connector] branch main updated: Fixed Kinesis shards failing tests.

[valdar]

This is an automated email from the ASF dual-hosted git repository.

valdar pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/main by this push:
     new 407ee92  Fixed Kinesis shards failing tests.
407ee92 is described below

commit 407ee920a5febae2d74d5947c8122be5ea774488
Author: Andrea Tarocchi <andrea.taroc...@gmail.com>
AuthorDate: Sat May 15 08:48:18 2021 +0200

    Fixed Kinesis shards failing tests.
---
 .../apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
 
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
index fb1d64a..de2e59c 100644
--- 
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
+++ 
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/kinesis/common/KinesisUtils.java
@@ -195,7 +195,7 @@ public final class KinesisUtils {
     private static boolean hasShards(KinesisClient kinesisClient, 
DescribeStreamRequest describeStreamRequest) {
         DescribeStreamResponse streamRes = 
kinesisClient.describeStream(describeStreamRequest);
 
-        return streamRes.streamDescription().shards().isEmpty();
+        return !streamRes.streamDescription().shards().isEmpty();
     }
 
     private static List<Shard> getAllShards(KinesisClient kinesisClient, 
DescribeStreamRequest describeStreamRequest) {