A. Sophie Blee-Goldman created KAFKA-12746:
----------------------------------------------
Summary: Allow StreamThreads to recover from some exceptions
without killing/replacing the thread
Key: KAFKA-12746
URL: https://issues.apache.org/jira/browse/KAFKA-12746
Project: Kafka
Issue Type: Sub-task
Components: streams
Reporter: A. Sophie Blee-Goldman
As the title says, in some cases it should be possible to recover the
StreamThread without killing and restarting it (it may in fact be _possible_
for all exception types, though in some cases it may be preferable to just let
the thread die and start up with a fresh thread).
This would obviously allow for greatly mitigating the impact of errors in the
subtopology, and allow us to retry with little overhead. It may also make it
easier to improve the processing semantics in the face of exceptions.
This will also be useful if/when we implement a more sophisticated task
scheduling which can, for example, work to deprioritize tasks that are
frequently experiencing errors without crashing the whole thread or dropping
the task entirely
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
