From a0021c532834fe4fd8c817af91a2d986898d32b7 Mon Sep 17 00:00:00 2001
From: Joshua Kim <kimjos@amazon.com>
Date: Tue, 23 Feb 2021 08:07:15 -0800
Subject: [PATCH] Fixing bug where ShardFilter parameter for ListShards was
 being passed in for paginated calls.

---
 .../services/kinesis/clientlibrary/proxies/KinesisProxy.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java
index 0936bddb..c1d7f10d 100644
--- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java
+++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java
@@ -315,13 +315,12 @@ public class KinesisProxy implements IKinesisProxyExtended {
         request.setRequestCredentials(credentialsProvider.getCredentials());
         if (StringUtils.isEmpty(nextToken)) {
             request.setStreamName(streamName);
+            request.setShardFilter(shardFilter);
         } else {
             request.setNextToken(nextToken);
         }
 
-        if (shardFilter != null) {
-            request.setShardFilter(shardFilter);
-        }
+        LOG.info("Listing shards with list shards request " + request);
 
         ListShardsResult result = null;
         LimitExceededException lastException = null;