Hi,
It makes sense looks like task 0_4 took more than max poll timeout time.
However I have difficulty processing following lines:
DEBUG 2017-03-01 18:17:42,465 [StreamThread-1]:
org.apache.kafka.streams.processor.internals.StreamThread - stream-thread
[StreamThread-1] creating new task 0_4
...
DE
Hi Sachin,
This is because another thread hasn't released the lock. It is generally
caused because it is taking a long time to restore or process the incoming
records. It might be helpful to take a Thread dump so we can see what each
thread is doing.
Thanks,
Damian
On Thu, 2 Mar 2017 at 12:14 Sa
Hi,
We are getting some deadlock state after re-balance and what we found that
it happens after re-balance the partition is assigned to a different thread
in same instance.
Looks like previous thread is not releasing the rocks db lock.
Here are the complete logs spanned across multiple files.
ht
