mjsax opened a new pull request, #23013: URL: https://github.com/apache/kafka/pull/23013
This PR ensures that we are assembling the latest task-(end)-offset sum snapshot only for the "streams" protocol, but not for "classic". For "classic" the snapshot is never read, so it's unnecessary to maintain it. It further ensure that we refresh the task-(end)-offset sum snapshot even if the main loop is not ready to process active tasks. The async state-updater thread might still make progress restoring standby and warmup tasks, so we should continue reporting the most recent metadata. -- 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]
