aws-s3
input can delete SQS entries before they're fully acknowledged
#38961
Labels
aws-s3
input can delete SQS entries before they're fully acknowledged
#38961
The SQS processing in the
aws-s3
input tracks the acknowledgment status of S3 objects with theEventACKTracker
helper. This helper has a bug where itsWait()
function unblocks not just if its pending counter is zero, but if its pending counter has ever been zero after the first event. This means that if all active events are acknowledged at some intermediate stage while additional events are still being downloaded / processed, all later events will be considered to be immediately acknowledged, and the SQS entry will be deleted as soon as events have been added to the queue (even if they have not been ingested upstream).The text was updated successfully, but these errors were encountered: