From 9553ec43e21b829b36a5b0300f69a0935646a99d Mon Sep 17 00:00:00 2001 From: Kris O'Mealy <3846175+komealy@users.noreply.github.com> Date: Thu, 20 Apr 2023 06:44:34 -0700 Subject: [PATCH] Info level is too chatty for this sleep message, debug is good. Signed-off-by: Kris O'Mealy Info level is too chatty for this sleep message, debug is good. Signed-off-by: Kris O'Mealy --- clientlibrary/worker/polling-shard-consumer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 }