[ https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16489485#comment-16489485 ]
Guozhang Wang commented on KAFKA-6943: -------------------------------------- Hi Antony, for this feature request, what are the common scenarios that caused a single task to fail, but not the whole thread to die? > Have option to shutdown KS cleanly if any task crashes, or if all tasks crash > ----------------------------------------------------------------------------- > > Key: KAFKA-6943 > URL: https://issues.apache.org/jira/browse/KAFKA-6943 > Project: Kafka > Issue Type: Improvement > Components: streams > Affects Versions: 1.1.0 > Reporter: Antony Stubbs > Priority: Major > > ATM users have to implement this themselves. Might be nice to have an option > to configure that if all tasks crash, or if any crash, to initiate clean > shutdown. > This also has a gotcha where atm if you call KS#close without a timeout, from > the uncaught exception handler, you dead lock. -- This message was sent by Atlassian JIRA (v7.6.3#76005)