Description
Currently, the internal interface for tasks is not very clean and it's hard to reason about the control flow when tasks get closes, suspended, resumed etc. This makes exception handling particularly hard.
We want to refactor this part of the code to get a clean control flow and interface.
Attachments
Issue Links
- blocks
-
KAFKA-4923 Add Exactly-Once Semantics to Streams
-
- Resolved
-
- links to
