[KAFKA-1038] fetch response should use empty messageset instead of null when handling errors

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.0
• Fix Version/s: 0.8.0
• Component/s: core
• Assignee: Jun Rao
• Reporter: Jun Rao
• Created: 03/Sep/13 04:26
• Updated: 13/Sep/13 23:30
• Resolved: 13/Sep/13 23:30

Description

Saw the following exception:

Exception when handling request (kafka.server.KafkaRequestHandler)
java.lang.NullPointerException
at
kafka.api.FetchResponsePartitionData.<init>(FetchResponse.scala:46)
at kafka.api.FetchRequest$$anonfun$2.apply(FetchRequest.scala:158)
at kafka.api.FetchRequest$$anonfun$2.apply(FetchRequest.scala:156)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233)
at
scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:178)
at
scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:347)
at
scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:347)
at
scala.collection.TraversableLike$class.map(TraversableLike.scala:233)
at scala.collection.immutable.HashMap.map(HashMap.scala:38)
at kafka.api.FetchRequest.handleError(FetchRequest.scala:156)
at kafka.server.KafkaApis.handle(KafkaApis.scala:78)
at
kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:42)
at java.lang.Thread.run(Thread.java:662)