C0urante opened a new pull request, #14316: URL: https://github.com/apache/kafka/pull/14316
[Jira](https://issues.apache.org/jira/browse/KAFKA-14725) This change tries to improve the shutdown semantics for source tasks by interrupting their poll-convert-produce thread when they've exceeded their graceful shutdown timeout. This is one possible measure to address the change in behavior described in [KAFKA-15090](https://issues.apache.org/jira/browse/KAFKA-15090), where the Connect runtime began invoking `SourceTask::stop` on the poll-convert-produce thread instead of on a separate thread. For reasons outlined on that ticket, reverting to the older behavior may be too drastic. Instead, we can explore this change first and, only if necessary, explore follow-up measures afterward. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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]
