ShivsundarR opened a new pull request, #17909:
URL: https://github.com/apache/kafka/pull/17909

   *What*
   There was a bug in handling the `ShareAcknowledgeResponse` for 
`commitAsync()`. Currently after we receive a response, we send out a 
background event to the application thread to update the acknowledgement commit 
callbacks for EVERY `TopicIdPartition`.
   The map that was sent was not cleared after sending the event. This meant we 
ended up sending responses for partitions that were already sent in the 
previous event. So there will be duplicate calls to the callback.
   
   The PR fixes the bug and adds a unit test for the same.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to