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 <[email protected]>
To: [email protected], [email protected]
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, <[email protected]> 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)
