I suspect the consumer logs should have some other exception too. Could you send around the entire consumer log as well as the consumer code snippet ? Also, do you have a test case ?
Thanks, Neha On Wed, Jul 18, 2012 at 4:27 AM, <zlai_2...@sina.com> wrote: > Hi all, > I use the kafka-0.7.1. But I find an exception in the logfile of > consumer client. I want to know how does it happen? How to solve it? > Thanks.The exception is like: > java.lang.IllegalStateException: Iterator is in failed state > at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:47) > at > bfd.kafkaconsumerclient.ConsumerInstance.getArray(ConsumerInstance.java:273) > at > bfd.kafkaconsumerclient.KafkaConsumerClientManagerI.getArray(KafkaConsumerClientManagerI.java:279) > at > bfd.kafkaconsumerclient._KafkaConsumerClientManagerDisp.___getArray(_KafkaConsumerClientManagerDisp.java:324) > at > bfd.kafkaconsumerclient._KafkaConsumerClientManagerDisp.__dispatch(_KafkaConsumerClientManagerDisp.java:594) > at IceInternal.Incoming.invoke(Incoming.java:159) > at Ice.ConnectionI.invokeAll(ConnectionI.java:2037) > at Ice.ConnectionI.message(ConnectionI.java:972) > at IceInternal.ThreadPool.run(ThreadPool.java:577) > at IceInternal.ThreadPool.access$100(ThreadPool.java:12) > at > IceInternal.ThreadPool$EventHandlerThread.run(ThreadPool.java:971)
