Nikita-Shupletsov opened a new pull request, #23093: URL: https://github.com/apache/kafka/pull/23093
* Added logic to catch and propagate to the stream thread fatal state update errors. * Improved the error handling logic in the state updater thread. Now when the thread is failing it marks all tasks as failed. * Added logic to fail task removal futures if the thread is dead. -- 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]
