You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by zl...@sina.com on 2012/07/18 13:27:22 UTC

an exception in the logfile of consumer client

 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)

Re: an exception in the logfile of consumer client

Posted by Neha Narkhede <ne...@gmail.com>.

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, <zl...@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)