Race Condition in KinesisDataFetcher
pfifer opened this issue · 0 comments
pfifer commented
When using the asynchronous retriever it's possible for the retriever to start multiple requests. When the requests are completed they update the next shard iterator in the KinesisDataFetcher. If multiple requests are initiated it's possible for there to be race to set the next shard iterator. This could cause records to be replayed or skipped.