Shivsundar R created KAFKA-18016:
------------------------------------

             Summary: Fix bugs in handling piggyback acknowledgements in 
ShareFetch
                 Key: KAFKA-18016
                 URL: https://issues.apache.org/jira/browse/KAFKA-18016
             Project: Kafka
          Issue Type: Sub-task
            Reporter: Shivsundar R


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.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to