Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Currently, when a ShareFetch is processed and response is received, we use the fetchAcknowledgements map to determine the acknowledgements sent per partition and call the callback accordingly. But there is a chance this map was updated by the ShareFetchEvent before the response was processed.
This means we could potentially lose out on sending acknowledgements. This bug was found while testing using the ShareRoundTripWorker with 100k records and a target production rate of 1000 messages per second.
Attachments
Issue Links
- links to