You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2012/07/25 20:52:34 UTC
[jira] [Created] (KAFKA-417) NullPointerException in
ZookeeperConsumerConnector
Neha Narkhede created KAFKA-417:
-----------------------------------
Summary: NullPointerException in ZookeeperConsumerConnector
Key: KAFKA-417
URL: https://issues.apache.org/jira/browse/KAFKA-417
Project: Kafka
Issue Type: Bug
Affects Versions: 0.8
Reporter: Neha Narkhede
Assignee: Jun Rao
[info] == kafka.integration.LazyInitProducerTest ==
[info] Test Starting: testProduceAndMultiFetch(kafka.integration.LazyInitProducerTest)
[2012-07-25 11:50:26,394] ERROR group1_consumer2 error during syncedRebalance (kafka.consumer.ZookeeperConsumerConnector:99)
java.lang.NullPointerException
at kafka.utils.ZkUtils$.getChildrenParentMayNotExist(ZkUtils.scala:371)
at kafka.utils.ZkUtils$.getCluster(ZkUtils.scala:389)
at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala
:444)
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:441)
at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:398)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-417) NullPointerException in
ZookeeperConsumerConnector
Posted by "Vaibhav Puranik (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13424159#comment-13424159 ]
Vaibhav Puranik commented on KAFKA-417:
---------------------------------------
I am using kafka 0.7.1 and I am getting many of these exceptions in my consumer. Here is my code - http://pastebin.com/qBnQLizj
Note that executeWithBatch is called again and again for every 5000 messages consumed. That means shutdown is getting called repeatedly.
> NullPointerException in ZookeeperConsumerConnector
> --------------------------------------------------
>
> Key: KAFKA-417
> URL: https://issues.apache.org/jira/browse/KAFKA-417
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.8
> Reporter: Neha Narkhede
> Assignee: Jun Rao
>
> [info] == kafka.integration.LazyInitProducerTest ==
> [info] Test Starting: testProduceAndMultiFetch(kafka.integration.LazyInitProducerTest)
> [2012-07-25 11:50:26,394] ERROR group1_consumer2 error during syncedRebalance (kafka.consumer.ZookeeperConsumerConnector:99)
> java.lang.NullPointerException
> at kafka.utils.ZkUtils$.getChildrenParentMayNotExist(ZkUtils.scala:371)
> at kafka.utils.ZkUtils$.getCluster(ZkUtils.scala:389)
> at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anonfun$syncedRebalance$1.apply$mcVI$sp(ZookeeperConsumerConnector.scala
> :444)
> 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:441)
> at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener$$anon$1.run(ZookeeperConsumerConnector.scala:398)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira