Hi guys, I am running a kafka instance and a zookeeper instance on the same ec2 instance. I have 2 consumer groups on the same topic. They work fine for few days but one of the consumers keeps stopping after few days. I can't see any exception in my application logs or kafka log. The thread of the stopping consumer is still running but consumer can't receive any message. Even I restart my application and it's still the same. I have to restart zookeeper and kafka to make it back to normal.
I used the following tool suggested by kafka docs and found owner is null after consumer stops working. also its consumer offset won't change any more. bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group mygroup --zkconnect 127.0.0.1:2181 --topic mytopic It's very similar with http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201207.mbox/%3c4ff59b1a.3080...@conduit.com%3E Any ideas about it? Thanks Ke