kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From <zlai_2...@sina.com>
Subject Re: Re: an exception in the logfile of consumer client
Date Thu, 19 Jul 2012 02:44:28 GMT
Thanks Neha,There is another exception, but it happened just one time. It like below:
java.lang.NullPointerException        at kafka.utils.ZkUtils$.getChildrenParentMayNotExist(ZkUtils.scala:181)
       at kafka.utils.ZkUtils$.getCluster(ZkUtils.scala:202)        at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala:447)
       at scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:282)   
    at scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265)        at
kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:444)
       at kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:733)
       at kafka.consumer.ZookeeperConsumerConnector.consume(ZookeeperConsumerConnector.scala:207)
       at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:77)
       at kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(ZookeeperConsumerConnector.scala:91)
       at bfd.kafkaconsumerclient.ConsumerInstance.Init(ConsumerInstance.java:167)       
at bfd.kafkaconsumerclient.ConsumerInstance.getArray(ConsumerInstance.java:275) 

But the exception "java.lang.IllegalStateException: Iterator is in failed state"  happened
frequently. And there are a lot of this exceptions in short time. I use client to consume
some topics that are not exist on zk. Does that has relation to the exception?Thanks.
----- Original Message -----
From: Neha Narkhede <neha.narkhede@gmail.com>
To: kafka-users@incubator.apache.org, zlai_2001@sina.com
Subject: Re: an exception in the logfile of consumer client
Date: 2012-07-19 01:09

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_2001@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)   


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