GitHub user rodesai opened a pull request: https://github.com/apache/kafka/pull/4343
KAFKA-6383: complete shutdown for CREATED StreamThreads When transitioning StreamThread from CREATED to PENDING_SHUTDOWN free up resources from the caller, rather than the stream thread, since in this case the stream thread was never actually started. In KakfaStreams.close, shut down the streams threads from the close thread. StreamThread.shutdown may now block, so call this from the close thread so that the timeout is honored. *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing strategy (including rationale) for the feature or bug fix. Unit and/or integration tests are expected for any behaviour change and system tests should be considered for larger changes.* ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) You can merge this pull request into a Git repository by running: $ git pull https://github.com/rodesai/kafka KAFKA-6383 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4343.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4343 ---- commit ab98a90027189dc12e3df99caf3d4f2aab8fefa0 Author: Rohan Desai <desai.p.ro...@gmail.com> Date: 2017-12-19T18:14:20Z KAFKA-6383: complete shutdown for CREATED StreamThreads When transitioning StreamThread from CREATED to PENDING_SHUTDOWN free up resources from the caller, rather than the stream thread, since in this case the stream thread was never actually started. In KakfaStreams.close, shut down the streams threads from the close thread. StreamThread.shutdown may now block, so call this from the close thread so that the timeout is honored. ---- ---