A. Sophie Blee-Goldman created KAFKA-12741:
----------------------------------------------
Summary: 4. Handle thread-wide errors
Key: KAFKA-12741
URL: https://issues.apache.org/jira/browse/KAFKA-12741
Project: Kafka
Issue Type: Sub-task
Components: streams
Reporter: A. Sophie Blee-Goldman
Although just implementing 1-3 will likely be a significant improvement, we
will eventually want to tackle the case of an exception that affects all tasks
on that thread. I think in this case we would just need to keep retrying the
specific call that’s failing, whatever that may be. This would almost certainly
require solution #3/4 as a prerequisite as we would need to keep retrying on
that thread’s Producer. Of course, with KIP-572 we’ll already retry most kinds
of errors on the Producer, if not all. So this would most likely only apply to
a few kinds of exceptions, such as any Consumer calls that fail for reasons
besides having dropped out of the group.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
