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

fix: check for non-zero cooldown period

Browse source 
Signed-off-by: Shiva Pentakota <spentakota@vmware.com>
This commit is contained in:
Shiva Pentakota 2023-03-22 20:46:24 -07:00
parent 711b72932a
commit 5c3fc2e477
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -187,8 +187,10 @@ func (sc *PollingShardConsumer) getRecords() error {
continue continue
} }
if err == maxBytesExceededError { if err == maxBytesExceededError {
log.Infof("maxBytesExceededError so sleep for %+v seconds", coolDownPeriod) if coolDownPeriod != 0 {
time.Sleep(time.Duration(coolDownPeriod) * time.Second) log.Infof("maxBytesExceededError so sleep for %+v seconds", coolDownPeriod)
time.Sleep(time.Duration(coolDownPeriod) * time.Second)
}
continue continue
} }
if errors.As(err, &kmsThrottlingErr) { if errors.As(err, &kmsThrottlingErr) {