Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - Re: ProducerThread NPE


Copy link to this message
-
Re: ProducerThread NPE
Jun Rao 2013-04-26, 15:01
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 <
[EMAIL PROTECTED]> 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