Hi again. I think I'm running into the Iterator issue mentioned here: http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201201.mbox/%3CCALMKdpuEJfjdo8eHoA-7jGfgp6HhzYiJZRrxLcQCfTK71o%3DgkQ%40mail.gmail.com%3E
I set up a 300 ms timeout. Once the timeout occurs, next time I ask for the iterator from the same strem, I get a: java.lang.IllegalStateException: Iterator is in failed state at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:47) at com.lucid.dao.queue.impl.kafka.KafkaConsumerIterator.hasNext( KafkaConsumerIterator.java:21) ..... ..... Note: I'm using the latest Kafka release. Any suggestion ? Thanks
