Gwen Shapira created KAFKA-3631:
-----------------------------------

             Summary: Recent addition of "nullable array" to MetadataRequest is 
breaking MirrorMaker system tests
                 Key: KAFKA-3631
                 URL: https://issues.apache.org/jira/browse/KAFKA-3631
             Project: Kafka
          Issue Type: Bug
            Reporter: Gwen Shapira


Here is the MirrorMaker log from last nights run:

{code}
[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)
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to