const KINESIS_SHARD_REFRESH_RATE: Duration;
Expand description

To read all data from a Kinesis stream, we need to continually update our knowledge of the stream’s shards by calling the ListShards API.

We will call ListShards at most this often to stay under the API rate limit (100x/sec per stream) and to improve source performance overall.