lianetm opened a new pull request, #21781: URL: https://github.com/apache/kafka/pull/21781
Mark partitions lost to avoid returning buffered records in the case of a race after the callback completes (app thread moves onto polling, while background moves onto clearing the lost assignment) Same fix applied for Consumer and Stream managers (Share has no callbacks so this does not apply) -- 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]
