Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-824

java.lang.NullPointerException in commitOffsets

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.7.2, 0.8.2.0
    • 0.9.0.0
    • consumer

    Description

      Neha Narkhede

      "Yes, I have. Unfortunately, I never quite around to fixing it. My guess is
      that it is caused due to a race condition between the rebalance thread and
      the offset commit thread when a rebalance is triggered or the client is
      being shutdown. Do you mind filing a bug ?"

      2013/03/25 12:08:32.020 WARN [ZookeeperConsumerConnector] [] 0_lu-ml-test10.bj-1364184411339-7c88f710 exception during commitOffsets
      java.lang.NullPointerException
      at org.I0Itec.zkclient.ZkConnection.writeData(ZkConnection.java:111)
      at org.I0Itec.zkclient.ZkClient$10.call(ZkClient.java:813)
      at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
      at org.I0Itec.zkclient.ZkClient.writeData(ZkClient.java:809)
      at org.I0Itec.zkclient.ZkClient.writeData(ZkClient.java:777)
      at kafka.utils.ZkUtils$.updatePersistentPath(ZkUtils.scala:103)
      at kafka.consumer.ZookeeperConsumerConnector$$anonfun$commitOffsets$2$$anonfun$apply$4.apply(ZookeeperConsumerConnector.scala:251)
      at kafka.consumer.ZookeeperConsumerConnector$$anonfun$commitOffsets$2$$anonfun$apply$4.apply(ZookeeperConsumerConnector.scala:248)
      at scala.collection.Iterator$class.foreach(Iterator.scala:631)
      at scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:549)
      at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
      at scala.collection.JavaConversions$JCollectionWrapper.foreach(JavaConversions.scala:570)
      at kafka.consumer.ZookeeperConsumerConnector$$anonfun$commitOffsets$2.apply(ZookeeperConsumerConnector.scala:248)
      at kafka.consumer.ZookeeperConsumerConnector$$anonfun$commitOffsets$2.apply(ZookeeperConsumerConnector.scala:246)
      at scala.collection.Iterator$class.foreach(Iterator.scala:631)
      at kafka.utils.Pool$$anon$1.foreach(Pool.scala:53)
      at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
      at kafka.utils.Pool.foreach(Pool.scala:24)
      at kafka.consumer.ZookeeperConsumerConnector.commitOffsets(ZookeeperConsumerConnector.scala:246)
      at kafka.consumer.ZookeeperConsumerConnector.autoCommit(ZookeeperConsumerConnector.scala:232)
      at kafka.consumer.ZookeeperConsumerConnector$$anonfun$1.apply$mcV$sp(ZookeeperConsumerConnector.scala:126)
      at kafka.utils.Utils$$anon$2.run(Utils.scala:58)
      at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
      at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351)
      at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178)
      at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
      at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
      at java.lang.Thread.run(Thread.java:722)

      Attachments

        1. ZkClient.0.4.txt
          90 kB
          Artur Denysenko
        2. ZkClient.0.3.txt
          90 kB
          Artur Denysenko
        3. screenshot-1.jpg
          543 kB
          Artur Denysenko

        Issue Links

          Activity

            People

              parth.brahmbhatt Parth Brahmbhatt
              yozhao Yonghui Zhao
              Votes:
              6 Vote for this issue
              Watchers:
              12 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: