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)