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.daughe...@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
