diff --git a/clientlibrary/worker/polling-shard-consumer.go b/clientlibrary/worker/polling-shard-consumer.go
index 6e19f5b..642f431 100644
--- a/clientlibrary/worker/polling-shard-consumer.go
+++ b/clientlibrary/worker/polling-shard-consumer.go
@@ -187,8 +187,10 @@ func (sc *PollingShardConsumer) getRecords() error {
 				continue
 			}
 			if err == maxBytesExceededError {
-				log.Infof("maxBytesExceededError so sleep for %+v seconds", coolDownPeriod)
-				time.Sleep(time.Duration(coolDownPeriod) * time.Second)
+				if coolDownPeriod != 0 {
+					log.Infof("maxBytesExceededError so sleep for %+v seconds", coolDownPeriod)
+					time.Sleep(time.Duration(coolDownPeriod) * time.Second)
+				}
 				continue
 			}
 			if errors.As(err, &kmsThrottlingErr) {