diff --git a/clientlibrary/worker/polling-shard-consumer.go b/clientlibrary/worker/polling-shard-consumer.go index 6c494a6..a35f026 100644 --- a/clientlibrary/worker/polling-shard-consumer.go +++ b/clientlibrary/worker/polling-shard-consumer.go @@ -285,6 +285,9 @@ func (sc *PollingShardConsumer) callGetRecordsAPI(gri *kinesis.GetRecordsInput) for _, record := range getResp.Records { sc.bytesRead += float64(len(record.Data)) } + if sc.lastCheckTime.IsZero() { + sc.lastCheckTime = rateLimitTimeNow() + } return getResp, err }