Hi, 

I am currently using kafka server 0.9 version. My kafka consumer version is 
0.8.2.2. I run into cases where my kafka consumer thread is down (when I check 
the threaddump, I can see my kafka consumer thread is down), but the server 
still thinks the kafka consumer thread is up and doesn't reallocate those 
partitions to other kafka consumers. 

This results in lag in those partitions which are allocated to consumer threads 
which are down. Is there anything that I can do to resolve this?

Thanks,
Sriram

Reply via email to