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