luciano/vmware-go-kcl-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Info level is too chatty for this sleep message, debug is good.

Browse source 
Signed-off-by: Kris O'Mealy <komealy@hotmail.com>

Info level is too chatty for this sleep message, debug is good.
Signed-off-by: Kris O'Mealy <komealy@hotmail.com>
This commit is contained in:
Kris O'Mealy 2023-04-20 06:44:34 -07:00 committed by komealy
parent b12921da23
commit 9553ec43e2
No known key found for this signature in database
GPG key ID: 873394803D205A88
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
clientlibrary/worker/polling-shard-consumer.go
View file

@ -176,12 +176,12 @@ func (sc *PollingShardConsumer) getRecords() error {
continue continue
} }
if err == localTPSExceededError { if err == localTPSExceededError {
log.Infof("localTPSExceededError so sleep for a second") log.Debugf("localTPSExceededError so sleep for a second")
sc.waitASecond(sc.currTime) sc.waitASecond(sc.currTime)
continue continue
} }
if err == maxBytesExceededError { 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) time.Sleep(time.Duration(coolDownPeriod) * time.Second)
continue continue
} }