diff --git a/amazon-kinesis-client-multilang/pom.xml b/amazon-kinesis-client-multilang/pom.xml index 2494e2e2..ea42b543 100644 --- a/amazon-kinesis-client-multilang/pom.xml +++ b/amazon-kinesis-client-multilang/pom.xml @@ -21,7 +21,7 @@ amazon-kinesis-client-pom software.amazon.kinesis - 2.2.4 + 2.2.5 4.0.0 diff --git a/amazon-kinesis-client/pom.xml b/amazon-kinesis-client/pom.xml index 2170b07b..e404725c 100644 --- a/amazon-kinesis-client/pom.xml +++ b/amazon-kinesis-client/pom.xml @@ -22,7 +22,7 @@ software.amazon.kinesis amazon-kinesis-client-pom - 2.2.4 + 2.2.5 amazon-kinesis-client diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java index 136f3a96..1f9ed9db 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java @@ -104,7 +104,7 @@ public class ShutdownTask implements ConsumerTask { if (localReason == ShutdownReason.SHARD_END) { allShards = shardDetector.listShards(); - if (!CollectionUtils.isNullOrEmpty(allShards) && !shardEndValidated(allShards)) { + if (!CollectionUtils.isNullOrEmpty(allShards) && !validateShardEnd(allShards)) { localReason = ShutdownReason.LEASE_LOST; } } @@ -190,16 +190,16 @@ public class ShutdownTask implements ConsumerTask { return reason; } - private boolean shardEndValidated(List shards) { + private boolean validateShardEnd(List shards) { for(Shard shard : shards) { - if (isChildShard(shard)) { + if (isChildShardOfCurrentShard(shard)) { return true; } } return false; } - private boolean isChildShard(Shard shard) { + private boolean isChildShardOfCurrentShard(Shard shard) { return (shard.parentShardId() != null && shard.parentShardId().equals(shardInfo.shardId()) || shard.adjacentParentShardId() != null && shard.adjacentParentShardId().equals(shardInfo.shardId())); } diff --git a/pom.xml b/pom.xml index 04bcaf7c..d967ab34 100644 --- a/pom.xml +++ b/pom.xml @@ -22,7 +22,7 @@ amazon-kinesis-client-pom pom Amazon Kinesis Client Library - 2.2.4 + 2.2.5 The Amazon Kinesis Client Library for Java enables Java developers to easily consume and process data from Amazon Kinesis.