From 41f996b833b099a2b6b8b268077ffe4e61fc7738 Mon Sep 17 00:00:00 2001
From: Micah Jaffe <31011877+micah-jaffe@users.noreply.github.com>
Date: Fri, 9 Aug 2019 14:05:08 -0700
Subject: [PATCH] Add logging around shard end codepaths (#585)

* Add logging around shard end codepaths

* Update logging messaging
---
 .../kinesis/clientlibrary/lib/worker/KinesisDataFetcher.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisDataFetcher.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisDataFetcher.java
index c1f6804d..e425e070 100644
--- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisDataFetcher.java
+++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisDataFetcher.java
@@ -77,6 +77,7 @@ class KinesisDataFetcher {
                 return TERMINAL_RESULT;
             }
         } else {
+            LOG.info("Skipping fetching records from Kinesis for shard " + shardId + ": nextIterator is null.");
             return TERMINAL_RESULT;
         }
     }
@@ -117,6 +118,7 @@ class KinesisDataFetcher {
                 lastKnownSequenceNumber = Iterables.getLast(result.getRecords()).getSequenceNumber();
             }
             if (nextIterator == null) {
+                LOG.info("Reached shard end: nextIterator is null in AdvancingResult.accept for shard " + shardId);
                 isShardEndReached = true;
             }
             return getResult();
@@ -167,6 +169,7 @@ class KinesisDataFetcher {
             nextIterator = getIterator(ShardIteratorType.AT_SEQUENCE_NUMBER.toString(), sequenceNumber);
         }
         if (nextIterator == null) {
+            LOG.info("Reached shard end: cannot advance iterator for shard " + shardId);
             isShardEndReached = true;
         }
         this.lastKnownSequenceNumber = sequenceNumber;