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
 			}