Bruno Cadonna created KAFKA-10500:
-------------------------------------

             Summary: Add API to Start and Stop Stream Threads
                 Key: KAFKA-10500
                 URL: https://issues.apache.org/jira/browse/KAFKA-10500
             Project: Kafka
          Issue Type: Sub-task
          Components: streams
            Reporter: Bruno Cadonna


Currently, there is no possibility in Kafka Streams to increase or decrease the 
number of stream threads after the Kafka Streams client has been started. 
Uncaught exceptions thrown in a stream thread kill the stream thread leaving 
the Kafka Streams client with less stream threads for processing than when the 
client was started. The only way to replace the killed stream thread is to 
restart the whole Kafka Streams client. For transient errors, it might make 
sense to replace a killed stream thread with a new one while users try to find 
the root cause of the error. That could be accomplished by starting a new 
stream thread in the uncaught exception handler of the killed stream thread.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to