From 5ba7d4502dc0323644a2cbcf84676b583ed7e1ae Mon Sep 17 00:00:00 2001
From: Joshua Kim <kimjos@amazon.com>
Date: Mon, 3 May 2021 12:47:40 -0700
Subject: [PATCH] Fixing logging

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

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 073c1d19..c6b641bb 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
@@ -490,7 +490,8 @@ public class KinesisProxy implements IKinesisProxyExtended {
         }
         final List<Shard> dedupedShards = new ArrayList<>(new LinkedHashSet<>(shards));
         if (dedupedShards.size() < shards.size()) {
-            LOG.warn("Found duplicate child shards in ListShards response. Request ids - " + requestIds);
+            LOG.warn("Found duplicate shards in response when sync'ing from Kinesis. " +
+                    "Request ids - " + requestIds + ". Response - " + shards);
         }
         this.cachedShardMap = dedupedShards.stream().collect(Collectors.toMap(Shard::getShardId, Function.identity()));
         this.lastCacheUpdateTime = Instant.now();