Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1038

fetch response should use empty messageset instead of null when handling errors

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.8.0
    • Component/s: core
    • Labels:
      None

      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)

        Attachments

        1. kafka-1038.patch
          1 kB
          Jun Rao

          Activity

            People

            • Assignee:
              junrao Jun Rao
              Reporter:
              junrao Jun Rao
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: