[
https://issues.apache.org/jira/browse/KAFKA-5349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030742#comment-16030742
]
ASF GitHub Bot commented on KAFKA-5349:
---------------------------------------
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/3175
KAFKA-5349: Fix illegal state error in consumer's ListOffset handler
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-5349
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3175.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 #3175
----
commit 12a38b4506494c76bc315526044dad9ec217ec80
Author: Jason Gustafson <ja...@confluent.io>
Date: 2017-05-31T07:05:19Z
KAFKA-5349: Fix illegal state error in consumer's ListOffset handler
----
> KafkaConsumer occasionally hits IllegalStateException
> -----------------------------------------------------
>
> Key: KAFKA-5349
> URL: https://issues.apache.org/jira/browse/KAFKA-5349
> Project: Kafka
> Issue Type: Bug
> Reporter: Apurva Mehta
> Assignee: Jason Gustafson
> Priority: Blocker
> Fix For: 0.11.0.0
>
>
> I have noticed the following while debugging system tests. Sometimes a plain
> old console consumer hits the following exception when reading from a topic:
> {noformat}
> [2017-05-30 22:16:55,686] ERROR Unknown error when running consumer:
> (kafka.tools.ConsoleConsumer$)
> java.lang.IllegalStateException: Invalid attempt to complete a request future
> which is already complete
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:145)
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:158)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher.handleListOffsetResponse(Fetcher.java:744)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher.access$2000(Fetcher.java:91)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher$3.onSuccess(Fetcher.java:688)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher$3.onSuccess(Fetcher.java:683)
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204)
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
> at
> org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:488)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:348)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:208)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:184)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher.retrieveOffsetsByTimes(Fetcher.java:451)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher.resetOffsets(Fetcher.java:409)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher.updateFetchPositions(Fetcher.java:282)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.updateFetchPositions(KafkaConsumer.java:1614)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1055)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1015)
> at kafka.consumer.NewShinyConsumer.<init>(BaseConsumer.scala:58)
> at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:72)
> at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
> at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
