[KAFKA-5786] Yet another exception is causing that streamming app is zombie

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Assignee: Unassigned
• Reporter: Seweryn Habdank-Wojewodzki
• Created: 25/Aug/17 08:40
• Updated: 31/Aug/17 09:32
• Resolved: 30/Aug/17 18:56

Description

Not handled exception in streamming app causes zombie state of the process.

2017-08-24 15:17:40 WARN  StreamThread:978 - stream-thread [kafka-endpoint-1236e6d5-75f0-4c14-b025-78e632484a26-StreamThread-3] Unexpected state transition from RUNNING to DEAD.
2017-08-24 15:17:40 FATAL StreamProcessor:67 - Caught unhandled exception: stream-thread [kafka-endpoint-1236e6d5-75f0-4c14-b025-78e632484a26-StreamThread-3] Failed to rebalance.; [org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:589), org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:553), org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:527)] in thread kafka-endpoint-1236e6d5-75f0-4c14-b025-78e632484a26-StreamThread-3

The final state of the app is similar to KAFKA-5779, but the exception and its location is in different place.

The exception shall be handled in the way that either application tries to continue working or shall completely quit if the error is not recoverable.

Current situation when application is zombie is not good.

Issue Links

• duplicates: KAFKA-5541 Streams should not re-throw if suspending/closing tasks fails