CODEWITHSUNDEEP
apache-kafkaapache-kafka-streams
zeller
zeller

Reputation: 4974

Can kafka streams restart crashed stream threads?

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.

Upvotes: 3

Views: 730

Answers (1)

wcarlson
wcarlson

Reputation: 226

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.

adding threads

restarting on failure

Upvotes: 2

Related Questions