Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> Re: ProducerThread NPE


Copy link to this message
-
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 <
[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

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB