From a7c063b99cdf91d659e30f6d1924137bd085f2f7 Mon Sep 17 00:00:00 2001
From: Shiva Pentakota <spentakota@vmware.com>
Date: Wed, 22 Mar 2023 12:22:26 -0700
Subject: [PATCH] chore: add info logs in sleep case for kinesis backoff errors

Signed-off-by: Shiva Pentakota <spentakota@vmware.com>
---
 clientlibrary/worker/polling-shard-consumer.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/clientlibrary/worker/polling-shard-consumer.go b/clientlibrary/worker/polling-shard-consumer.go
index 28c1f6a..6e19f5b 100644
--- a/clientlibrary/worker/polling-shard-consumer.go
+++ b/clientlibrary/worker/polling-shard-consumer.go
@@ -182,10 +182,12 @@ func (sc *PollingShardConsumer) getRecords() error {
 				continue
 			}
 			if err == localTPSExceededError {
+				log.Infof("localTPSExceededError so sleep for a second")
 				sc.waitASecond(sc.currTime)
 				continue
 			}
 			if err == maxBytesExceededError {
+				log.Infof("maxBytesExceededError so sleep for %+v seconds", coolDownPeriod)
 				time.Sleep(time.Duration(coolDownPeriod) * time.Second)
 				continue
 			}