[
https://issues.apache.org/jira/browse/KAFKA-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261229#comment-15261229
]
ASF GitHub Bot commented on KAFKA-3631:
---------------------------------------
GitHub user granthenke opened a pull request:
https://github.com/apache/kafka/pull/1279
KAFKA-3631: Fix Struct.toString for nullable arrayOf
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/granthenke/kafka struct-fix
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/1279.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1279
----
commit 4a1a67527dd60c06e64f5b373621af66812f3ed8
Author: Grant Henke <granthe...@gmail.com>
Date: 2016-04-27T23:49:04Z
KAFKA-3631: Fix Struct.toString for nullable arrayOf
----
> 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)
