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

Merge pull request #27 from vmware/spentakota_AddLogs

Browse source 
chore: add info logs in sleep case for kinesis backoff errors
This commit is contained in:
spentakota 2023-03-22 14:43:58 -07:00 committed by GitHub
commit 711b72932a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -182,10 +182,12 @@ func (sc *PollingShardConsumer) getRecords() error {
continue continue
} }
if err == localTPSExceededError { if err == localTPSExceededError {
log.Infof("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)
time.Sleep(time.Duration(coolDownPeriod) * time.Second) time.Sleep(time.Duration(coolDownPeriod) * time.Second)
continue continue
} }