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:

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

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