Compare commits

...

1 commit

Author SHA1 Message Date
Shiva Pentakota
5c3fc2e477 fix: check for non-zero cooldown period
Signed-off-by: Shiva Pentakota <spentakota@vmware.com>
2023-03-22 20:46:24 -07:00

View file

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