Matthias J. Sax created KAFKA-4510:
--------------------------------------
Summary: StreamThread must finish rebalance in state
PENDING_SHUTDOWN
Key: KAFKA-4510
URL: https://issues.apache.org/jira/browse/KAFKA-4510
Project: Kafka
Issue Type: Bug
Components: streams
Reporter: Matthias J. Sax
Assignee: Matthias J. Sax
If a Streams application runs with multiple threads within one JVM and the
application gets stopped. this can triggers a rebalance when the first threads
finishes processing because not all thread shut down at the same time.
Because we try to reuse tasks, on rebalance task are not closed immediately in
order for a potential reuse (if a task gets assigned the its original thread).
However, if a thread is in state {{PENDING_SHUTDOWN}} it does finish the
rebalance operation completely and thus does not release the suspended task and
the application exits with not all locks released.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
