kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Patricio Echagüe <patric...@gmail.com>
Subject Consumer iterator error
Date Thu, 05 Jan 2012 20:37:49 GMT
Hi again. I think I'm running into the Iterator issue mentioned here:


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(



Note: I'm using the latest Kafka release.

Any suggestion ?


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message