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

0.9.0.0 broker crash on receipt of produce request with empty client ID

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.9.0.0
    • Fix Version/s: 0.9.0.2, 0.10.0.0
    • Component/s: producer
    • Labels:
      None

      Description

      Sending a produce request with an empty client ID to a 0.9.0.0 broker causes the broker to crash as shown below. More details can be found in the following email thread:

      http://mail-archives.apache.org/mod_mbox/kafka-users/201601.mbox/%3c5693ECD9.4050400@dspeterson.com%3e

      [2016-01-10 23:03:44,957] ERROR [KafkaApi-3] error when handling request Name: ProducerRequest; Version: 0; CorrelationId: 1; ClientId: null; RequiredAcks: 1; AckTimeoutMs: 10000 ms; TopicAndPartition: [topic_1,3] -> 37 (kafka.server.KafkaApis)
      java.lang.NullPointerException
      at org.apache.kafka.common.metrics.JmxReporter.getMBeanName(JmxReporter.java:127)
      at org.apache.kafka.common.metrics.JmxReporter.addAttribute(JmxReporter.java:106)
      at org.apache.kafka.common.metrics.JmxReporter.metricChange(JmxReporter.java:76)
      at org.apache.kafka.common.metrics.Metrics.registerMetric(Metrics.java:288)
      at org.apache.kafka.common.metrics.Sensor.add(Sensor.java:177)
      at org.apache.kafka.common.metrics.Sensor.add(Sensor.java:162)
      at kafka.server.ClientQuotaManager.getOrCreateQuotaSensors(ClientQuotaManager.scala:209)
      at kafka.server.ClientQuotaManager.recordAndMaybeThrottle(ClientQuotaManager.scala:111)
      at kafka.server.KafkaApis.kafka$server$KafkaApis$$sendResponseCallback$2(KafkaApis.scala:353)
      at kafka.server.KafkaApis$$anonfun$handleProducerRequest$1.apply(KafkaApis.scala:371)
      at kafka.server.KafkaApis$$anonfun$handleProducerRequest$1.apply(KafkaApis.scala:371)
      at kafka.server.ReplicaManager.appendMessages(ReplicaManager.scala:348)
      at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:366)
      at kafka.server.KafkaApis.handle(KafkaApis.scala:68)
      at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
      at java.lang.Thread.run(Thread.java:745)

        Attachments

          Activity

            People

            • Assignee:
              granthenke Grant Henke
              Reporter:
              dspeterson Dave Peterson
            • Votes:
              0 Vote for this issue
              Watchers:
              8 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: