From c2a3f18670e7d89a04b0608ac954cafa7407f087 Mon Sep 17 00:00:00 2001
From: Micah Jaffe <31011877+micah-jaffe@users.noreply.github.com>
Date: Tue, 13 Aug 2019 13:18:52 -0700
Subject: [PATCH] Update ShardEnd checkpoint failure messaging (#591)

* Update shard end checkpoint failure messaging

* Update shard end checkpoint failure messaging
---
 .../java/software/amazon/kinesis/lifecycle/ShutdownTask.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 bb3c3de3..edb69649 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
@@ -106,8 +106,9 @@ public class ShutdownTask implements ConsumerTask {
                         ExtendedSequenceNumber lastCheckpointValue = recordProcessorCheckpointer.lastCheckpointValue();
                         if (lastCheckpointValue == null
                                 || !lastCheckpointValue.equals(ExtendedSequenceNumber.SHARD_END)) {
-                            throw new IllegalArgumentException(
-                                    "Application didn't checkpoint at end of shard " + shardInfo.shardId());
+                            throw new IllegalArgumentException("Application didn't checkpoint at end of shard "
+                                    + shardInfo.shardId() + ". Application must checkpoint upon shard end. " +
+                                    "See ShardRecordProcessor.shardEnded javadocs for more information.");
                         }
                     } else {
                         shardRecordProcessor.leaseLost(LeaseLostInput.builder().build());