[ 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)