[KAFKA-9331] Add option to terminate application when StreamThread(s) die

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Duplicate
• Affects Version/s: 2.4.0
• Component/s: streams
• Labels: needs-kip
• Assignee: Walker Carlson
• Reporter: Michael Bingham
• Created: 23/Dec/19 23:35
• Updated: 24/Feb/21 23:20
• Resolved: 30/Dec/19 18:29

Description

Currently, if a StreamThread dies due to an unexpected exception, the Streams application continues running. Even if all StreamThread(s) die, the application will continue running, but will be in an ERROR state. 

Many users want or expect the application to terminate in the event of a fatal exception that kills one or more StreamThread(s). Currently, this requires extra work from the developer to register an uncaught exception handler on the KafkaStreams object and trigger a shutdown as needed.

It would be useful to provide a configurable option for the Streams application to have it automatically terminate with an exception if one or more StreamThread(s) die.

 

 

Issue Links

• duplicates: KAFKA-6943 Have option to shutdown KS cleanly if any threads crashes, or if all threads crash
• links to: GitHub Pull Request #9273
• links to: GitHub Pull Request #9487
• mentioned in: Page Loading...