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 d6282cff..91ea125b 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 @@ -144,7 +144,7 @@ public class ShutdownTask implements ConsumerTask { // if childshards is empty. When child shards is empty then either it is due to // completed shard being reprocessed or we got RNF from service. // For these cases enqueue the lease for deletion. - if (isSuccess || !CollectionUtils.isNullOrEmpty(childShards)) { + if (isSuccess || CollectionUtils.isNullOrEmpty(childShards)) { leaseCleanupManager.enqueueForDeletion(leasePendingDeletion); } }