[ 
https://issues.apache.org/jira/browse/KAFKA-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261069#comment-15261069
 ] 

Gwen Shapira commented on KAFKA-3631:
-------------------------------------

More important, our network processor got that NPE:

{code}

2016-04-27 10:10:34,470] ERROR Processor got uncaught exception. 
(kafka.network.Processor)
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 
kafka.network.RequestChannel$Request.kafka$network$RequestChannel$Request$$requestDesc(RequestChannel.scala:102)
        at 
kafka.network.RequestChannel$Request.updateRequestMetrics(RequestChannel.scala:154)
        at 
kafka.network.Processor$$anonfun$processCompletedSends$1.apply(SocketServer.scala:505)
        at 
kafka.network.Processor$$anonfun$processCompletedSends$1.apply(SocketServer.scala:501)
        at scala.collection.Iterator$class.foreach(Iterator.scala:727)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
        at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
        at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
        at kafka.network.Processor.processCompletedSends(SocketServer.scala:501)
        at kafka.network.Processor.run(SocketServer.scala:414)
        at java.lang.Thread.run(Thread.java:745)

{code}

We should probably check if the network processor absolutely needs to throw up 
on Struct.toString() failures.

> 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
>            Assignee: Grant Henke
>
> 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