You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Drew Daugherty <Dr...@returnpath.com> on 2013/04/26 16:04:54 UTC
ProducerThread NPE
Hi,
We are using Kafka 0.7.2 and are seeing the following exceptions in the ProducerSendThread:
2013-04-25 13:00:56,557 [ProducerSendThread--416074535] ERROR kafka.producer.async.ProducerSendThread - Error in handling batch of 2 events
java.lang.NullPointerException
at kafka.producer.async.DefaultEventHandler$$anonfun$collate$1$$anonfun$6.apply(DefaultEventHandler.scala:120)
at kafka.producer.async.DefaultEventHandler$$anonfun$collate$1$$anonfun$6.apply(DefaultEventHandler.scala:120)
at scala.collection.TraversableLike$$anonfun$partition$1.apply(TraversableLike.scala:313)
at scala.collection.TraversableLike$$anonfun$partition$1.apply(TraversableLike.scala:313)
at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
at scala.collection.immutable.List.foreach(List.scala:45)
at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:44)
at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:42)
at scala.collection.TraversableLike$class.partition(TraversableLike.scala:313)
at scala.collection.mutable.ListBuffer.partition(ListBuffer.scala:42)
at kafka.producer.async.DefaultEventHandler$$anonfun$collate$1.apply(DefaultEventHandler.scala:120)
at kafka.producer.async.DefaultEventHandler$$anonfun$collate$1.apply(DefaultEventHandler.scala:119)
at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
at scala.collection.immutable.List.foreach(List.scala:45)
at kafka.producer.async.DefaultEventHandler.collate(DefaultEventHandler.scala:119)
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:44)
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:116)
at kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:95)
at kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:71)
at scala.collection.immutable.Stream.foreach(Stream.scala:260)
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:70)
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:41)
-drew
RE: ProducerThread NPE
Posted by Drew Daugherty <Dr...@returnpath.com>.
That was it. Thanks for the prompt response.
-drew
________________________________________
From: Jun Rao [junrao@gmail.com]
Sent: Friday, April 26, 2013 9:00 AM
To: users@kafka.apache.org
Subject: Re: ProducerThread NPE
Is it possible that you didn't set topic in ProducerData when calling
producer.send()?
Thanks,
Jun
On Fri, Apr 26, 2013 at 7:04 AM, Drew Daugherty <
Drew.Daugherty@returnpath.com> wrote:
> Hi,
>
> We are using Kafka 0.7.2 and are seeing the following exceptions in the
> ProducerSendThread:
>
> 2013-04-25 13:00:56,557 [ProducerSendThread--416074535] ERROR
> kafka.producer.async.ProducerSendThread - Error in handling batch of 2
> events
> java.lang.NullPointerException
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$collate$1$$anonfun$6.apply(DefaultEventHandler.scala:120)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$collate$1$$anonfun$6.apply(DefaultEventHandler.scala:120)
> at
> scala.collection.TraversableLike$$anonfun$partition$1.apply(TraversableLike.scala:313)
> at
> scala.collection.TraversableLike$$anonfun$partition$1.apply(TraversableLike.scala:313)
> at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
> at scala.collection.immutable.List.foreach(List.scala:45)
> at
> scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:44)
> at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:42)
> at
> scala.collection.TraversableLike$class.partition(TraversableLike.scala:313)
> at
> scala.collection.mutable.ListBuffer.partition(ListBuffer.scala:42)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$collate$1.apply(DefaultEventHandler.scala:120)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$collate$1.apply(DefaultEventHandler.scala:119)
> at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
> at scala.collection.immutable.List.foreach(List.scala:45)
> at
> kafka.producer.async.DefaultEventHandler.collate(DefaultEventHandler.scala:119)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:44)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:116)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:95)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:71)
> at scala.collection.immutable.Stream.foreach(Stream.scala:260)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:70)
> at
> kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:41)
>
> -drew
Re: ProducerThread NPE
Posted by Jun Rao <ju...@gmail.com>.
Is it possible that you didn't set topic in ProducerData when calling
producer.send()?
Thanks,
Jun
On Fri, Apr 26, 2013 at 7:04 AM, Drew Daugherty <
Drew.Daugherty@returnpath.com> wrote:
> Hi,
>
> We are using Kafka 0.7.2 and are seeing the following exceptions in the
> ProducerSendThread:
>
> 2013-04-25 13:00:56,557 [ProducerSendThread--416074535] ERROR
> kafka.producer.async.ProducerSendThread - Error in handling batch of 2
> events
> java.lang.NullPointerException
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$collate$1$$anonfun$6.apply(DefaultEventHandler.scala:120)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$collate$1$$anonfun$6.apply(DefaultEventHandler.scala:120)
> at
> scala.collection.TraversableLike$$anonfun$partition$1.apply(TraversableLike.scala:313)
> at
> scala.collection.TraversableLike$$anonfun$partition$1.apply(TraversableLike.scala:313)
> at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
> at scala.collection.immutable.List.foreach(List.scala:45)
> at
> scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:44)
> at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:42)
> at
> scala.collection.TraversableLike$class.partition(TraversableLike.scala:313)
> at
> scala.collection.mutable.ListBuffer.partition(ListBuffer.scala:42)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$collate$1.apply(DefaultEventHandler.scala:120)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$collate$1.apply(DefaultEventHandler.scala:119)
> at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
> at scala.collection.immutable.List.foreach(List.scala:45)
> at
> kafka.producer.async.DefaultEventHandler.collate(DefaultEventHandler.scala:119)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:44)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:116)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:95)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:71)
> at scala.collection.immutable.Stream.foreach(Stream.scala:260)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:70)
> at
> kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:41)
>
> -drew