This may or may not help. I found it to be a clever workaround for some of the limitations in the 8.x version of the high level consumer... I ended up writing code that "waited" a lot because I couldn't be sure how quickly Kafka would respond...
Nothing ever took minutes however... the waits were 30 seconds or so if I recall... In case it helps... http://ingest.tips/2014/10/12/kafka-high-level-consumer-frequently-missing- pieces/ On Thu, May 5, 2016 at 4:58 AM, sahitya agrawal <[email protected]> wrote: > I am using high level consumer API ( Kafka API version 0.9.0.0 ) > > I am running consumers on a topic of 10 partitions. There are lot of unread > messages in that topic. Initially all of them , consume from the topic and > read messages. After sometime, all of them hangs and doesn't read any > message at all. > I have to manually restart them to make them consume again. > Surprisingly I do not see any exception or error in logs also. > > Has anybody ever faced this issue? >
