ShivsundarR opened a new pull request, #16727: URL: https://github.com/apache/kafka/pull/16727
In ShareConsumeRequestManager, currently every time we perform a `commitSync`/`commitAsync`/`acknowledgeOnClose` we create one AcknowledgeRequestState for each call. But this can be optimised further as we can batch up the acknowledgements to be sent to the same node. We can optimise the number of RPC calls by batching the acknowledgements before the next poll is invoked per node. This will ensure that between 2 polls, the acknowledgements are accumulated in one request per node and then sent during poll, resulting in lesser RPC calls. We are storing a pair of acknowledge request states for every node, the first value denotes the requestState for commitAsync() and the second value denotes the requestState for commitSync() and acknowledgeOnClose(). -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
