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