Description
Currently, Streams suspends tasks on rebalance and closes suspended tasks if not reassigned. During close, suspend() is called a second time, also calling Processor.close() for all nodes again.
It would be safer to only call suspend() once in case users have non-idempotent operations in Processor.close() method and might thus fail. (cf. KAFKA-5167)
Attachments
Issue Links
- contains
-
KAFKA-5145 Remove task close() call from closeNonAssignedSuspendedTasks method
- Resolved
- incorporates
-
KAFKA-5167 streams task gets stuck after re-balance due to LockException
- Resolved
- links to