[jira] [Updated] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

2018-03-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5697: - Labels: newbie (was: ) > StreamThread.close() need to interrupt the stream threads to break the

[jira] [Updated] (KAFKA-5697) StreamThread.close() need to interrupt the stream threads to break the loop

2018-01-18 Thread Mariam John (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John updated KAFKA-5697: --- Description: In {{StreamThread.close()}} we currently do nothing but set the state, hoping the