ShivsundarR opened a new pull request, #18851: URL: https://github.com/apache/kafka/pull/18851
*What* Currently when we fetch records from a node and then there is a leadership change before we acknowledge, we attempt to send the acknowledgements to the old leader. This was just the case when the leadership changes before we acknowledge, if the leadership change happened after, we would get a `NOT_LEADER_OR_FOLLOWER` exception from the broker in the response. In order to have a consistent behaviour, we will now fail the acknowledgements with `NOT_LEADER_OR_FOLLOWER` exception in the clients and avoid sending the request to the previous leader. These records would now timeout and be re-acquired in the next fetch cycle. -- 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]
