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 9c77d910..dd98ca87 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 @@ -146,6 +146,8 @@ public class ShutdownTask implements ConsumerTask { // in the case of RNF Exception. attemptShardEndCheckpointing(scope, startTime); } finally { + // If we don't want to cleanup the garbage shard without successful shard end + // checkpointing, remove the try finally construct and only execute the methods. attemptGarbageCollectionOfLeaseAndEnqueueOnFailure(leasePendingDeletion, currentShardLease); } }