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
