Anh Le created KAFKA-6541:
-----------------------------
Summary: StackOverflow exceptions in thread
'kafka-coordinator-heartbeat-thread
Key: KAFKA-6541
URL: https://issues.apache.org/jira/browse/KAFKA-6541
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 1.0.0
Environment: Linux
Reporter: Anh Le
There's something wrong with our client library when sending heart beats. This
bug seems to be identical to this one:
[http://mail-archives.apache.org/mod_mbox/kafka-users/201712.mbox/%3CCALte62w6=pJObC+i36BkoqbOLTKsQ=nrddv6dm8abfwb5ps...@mail.gmail.com%3E]
Here's the log:
{{2018-02-08 13:55:01,102 ERROR
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread
Uncaught exception in thread 'kafka-coordinator-heartbeat-thread |
default-group':}}
{{java.lang.StackOverflowError: null}}
{{ at java.lang.StringBuilder.append(StringBuilder.java:136)}}
{{ at
org.slf4j.helpers.MessageFormatter.safeObjectAppend(MessageFormatter.java:302)}}
{{ 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
ch.qos.logback.classic.spi.LoggingEvent.getFormattedMessage(LoggingEvent.java:293)}}
{{ at
ch.qos.logback.classic.spi.LoggingEvent.prepareForDeferredProcessing(LoggingEvent.java:206)}}
{{ at
ch.qos.logback.core.OutputStreamAppender.subAppend(OutputStreamAppender.java:223)}}
{{ at
ch.qos.logback.core.OutputStreamAppender.append(OutputStreamAppender.java:102)}}
{{ at
ch.qos.logback.core.UnsynchronizedAppenderBase.doAppend(UnsynchronizedAppenderBase.java:84)}}
{{ at
ch.qos.logback.core.spi.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:51)}}
{{ at ch.qos.logback.classic.Logger.appendLoopOnAppenders(Logger.java:270)}}
{{ at ch.qos.logback.classic.Logger.callAppenders(Logger.java:257)}}
{{ at
ch.qos.logback.classic.Logger.buildLoggingEventAndAppend(Logger.java:421)}}
{{ at ch.qos.logback.classic.Logger.filterAndLog_1(Logger.java:398)}}
{{ at ch.qos.logback.classic.Logger.info(Logger.java:583)}}
{{ at
org.apache.kafka.common.utils.LogContext$KafkaLogger.info(LogContext.java:341)}}
{{ at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.coordinatorDead(AbstractCoordinator.java:649)}}
{{ at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onFailure(AbstractCoordinator.java:797)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture$1.onFailure(RequestFuture.java:209)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture.fireFailure(RequestFuture.java:177)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:147)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:496)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:353)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.failUnsentRequests(ConsumerNetworkClient.java:416)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.disconnect(ConsumerNetworkClient.java:388)}}
{{ at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.coordinatorDead(AbstractCoordinator.java:653)}}
{{ at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onFailure(AbstractCoordinator.java:797)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture$1.onFailure(RequestFuture.java:209)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture.fireFailure(RequestFuture.java:177)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:147)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:496)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:353)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.failUnsentRequests(ConsumerNetworkClient.java:416)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.disconnect(ConsumerNetworkClient.java:388)}}
{{ at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.coordinatorDead(AbstractCoordinator.java:653)}}
{{ at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onFailure(AbstractCoordinator.java:797)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture$1.onFailure(RequestFuture.java:209)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture.fireFailure(RequestFuture.java:177)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:147)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:496)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:353)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.failUnsentRequests(ConsumerNetworkClient.java:416)}}
{{ at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.disconnect(ConsumerNetworkClient.java:388)}}
{{ at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.coordinatorDead(AbstractCoordinator.java:653)}}
{{ at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onFailure(AbstractCoordinator.java:797)}}
{{ at
org.apache.kafka.clients.consumer.internals.RequestFuture$1.onFailure(RequestFuture.java:209)}}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
