Matthias J. Sax created KAFKA-5485: -------------------------------------- Summary: Streams should not suspend tasks twice Key: KAFKA-5485 URL: https://issues.apache.org/jira/browse/KAFKA-5485 Project: Kafka Issue Type: Improvement Components: streams Affects Versions: 0.11.1.0 Reporter: Matthias J. Sax Assignee: Matthias J. Sax Priority: Minor
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) -- This message was sent by Atlassian JIRA (v6.4.14#64029)