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

Recent addition of "nullable array" to MetadataRequest is breaking MirrorMaker system tests

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.10.0.0
    • Component/s: None
    • Labels:
      None

      Description

      Here is the MirrorMaker log from last nights run:

      [2016-04-27 10:05:44,721] DEBUG Set SASL client state to COMPLETE (org.apache.kafka.common.security.authenticator.SaslClientAuthenticator)
      SLF4J: Failed toString() invocation on an object of type [org.apache.kafka.common.requests.MetadataRequest]
      Reported exception:
      java.lang.NullPointerException
      	at org.apache.kafka.common.protocol.types.Struct.toString(Struct.java:296)
      	at org.apache.kafka.common.requests.AbstractRequestResponse.toString(AbstractRequestResponse.java:47)
      	at org.slf4j.helpers.MessageFormatter.safeObjectAppend(MessageFormatter.java:299)
      	at org.slf4j.helpers.MessageFormatter.deeplyAppendParameter(MessageFormatter.java:271)
      	at org.slf4j.helpers.MessageFormatter.arrayFormat(MessageFormatter.java:233)
      	at org.slf4j.helpers.MessageFormatter.arrayFormat(MessageFormatter.java:173)
      	at org.slf4j.helpers.MessageFormatter.format(MessageFormatter.java:151)
      	at org.slf4j.impl.Log4jLoggerAdapter.debug(Log4jLoggerAdapter.java:252)
      	at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:640)
      	at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:552)
      	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:258)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:338)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:212)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:191)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:161)
      	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorKnown(AbstractCoordinator.java:179)
      	at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:898)
      	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:864)
      	at kafka.tools.MirrorMaker$MirrorMakerNewConsumer.receive(MirrorMaker.scala:557)
      	at kafka.tools.MirrorMaker$MirrorMakerThread.run(MirrorMaker.scala:412)
      [2016-04-27 10:05:44,785] DEBUG Sending metadata request [FAILED toString()] to node 1 (org.apache.kafka.clients.NetworkClient)
      

        Attachments

          Activity

            People

            • Assignee:
              granthenke Grant Henke
              Reporter:
              gwenshap Gwen Shapira
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: