I couldn't find anything on this in the documentation. Consider you have props.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 2);
and a stream task crashes with an uncaught exception.
Can you somehow force its restart? Based on my experiments, crashed processor threads don't restart.
Can kafka streams restart crashed stream threads?
Viewed 211
1 Answers
There is currently no way to do this with out relaunching the client. The ability to close the crashed threads and create replacements along with improved exception handling will be introduced in version 2.8.
Related