Lucas Brutschy created KAFKA-19510:
--------------------------------------
Summary: Kafka Streams does not always release lock when adding or
removing threads multiple times
Key: KAFKA-19510
URL: https://issues.apache.org/jira/browse/KAFKA-19510
Project: Kafka
Issue Type: Bug
Reporter: Lucas Brutschy
Kafka Streams seems to not always release the state directory lock for all
tasks, when threads are added / removed.
It seems this problem is related to
[https://github.com/apache/kafka/pull/16922].
Effectively, the old thread (same name, different object) still seems to own
the task.
To reproduce, checkout
https://github.com/lucasbru/kafka/commit/2701dd39fe7df23a123939a1c9e140c849904b5f
and run `AdjustStreamThreadCountTest >
shouldAddAndRemoveThreadsMultipleTimes` ... multiple times.
The test was changed to use a stateful topology.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
