[
https://issues.apache.org/jira/browse/KAFKA-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16297675#comment-16297675
]
Guozhang Wang commented on KAFKA-6383:
--------------------------------------
[~rohanpd] I have added you to the contributor list, you can assign yourself to
JIRAs now.
> StreamThread.shutdown doesn't clean up completely when called before
> StreamThread.start
> ---------------------------------------------------------------------------------------
>
> Key: KAFKA-6383
> URL: https://issues.apache.org/jira/browse/KAFKA-6383
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 1.0.0
> Reporter: Rohan Desai
> Assignee: Rohan Desai
>
> The following code leaks a producer network thread:
> {code}
> ks = new KafkaStreams(...);
> ks.close();
> {code}
> The underlying issue is that KafkaStreams creates a bunch of StreamsThreads
> via StreamThread.create, which in turn creates a bunch of stuff (including a
> producer). These resources are cleaned up only when the thread exits. So if
> the thread was never started, then they are never cleaned up.
> StreamThread.shutdown should clean up if it sees that the thread has never
> been started.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
