Hi,
We are facing a peculiar situation in the 2.3 version of Kafka Streams. First
of all, I want to clarify if it is possible that a Stream Thread (say Stream
Thread-1) which had got an assignment for a standby task (say 0_0) can change
to Stream Thread-2 on the same host post rebalancing. The issue we are facing
is this is happening for us and post rebalancing since the Stream Thread-1 had
0_0 and is not assigned back to it, it closes that task and marks it for
deletion(after cleanup delay time), and meanwhile, the task gets assigned to
Stream Thread-2. When the Stream Thread-2 tries to transition this task to
Running, it gets a LockException which is caught in
AssignedTasks#initializeNewTasks(). This makes 0_0 stay in Created state on
Stream Thread-2 and after the cleanup delay is over the task directories for
0_0 get deleted.
Can someone please comment on this behavior.
Thanks,Navinder
