[ https://issues.apache.org/jira/browse/KAFKA-3590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399460#comment-15399460 ]
ASF GitHub Bot commented on KAFKA-3590: --------------------------------------- GitHub user cotedm opened a pull request: https://github.com/apache/kafka/pull/1681 KAFKA-3590: KafkaConsumer fails with "Messages are rejected since there are fewer in-sync replicas than required." when polling This just improves the error message since it's confusing that a consumer throws a message you'd normally see for a producer. You can merge this pull request into a Git repository by running: $ git pull https://github.com/cotedm/kafka KAFKA-3590 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1681.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 #1681 ---- commit 9873e9fa94c8781dccb390cde890c48f9aa5ffc5 Author: Dustin Cote <dus...@confluent.io> Date: 2016-07-29T14:59:10Z Handle error case for under replicated __consumer_offsets by logging a better message commit 45c0d6cd9e4192fae6f44a308812679f8fdb3fd3 Author: Dustin Cote <dus...@confluent.io> Date: 2016-07-29T15:02:28Z updated comment ---- > KafkaConsumer fails with "Messages are rejected since there are fewer in-sync > replicas than required." when polling > ------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-3590 > URL: https://issues.apache.org/jira/browse/KAFKA-3590 > Project: Kafka > Issue Type: Bug > Components: consumer > Affects Versions: 0.9.0.1 > Environment: JDK1.8 Ubuntu 14.04 > Reporter: Sergey Alaev > Assignee: Dustin Cote > > KafkaConsumer.poll() fails with "Messages are rejected since there are fewer > in-sync replicas than required.". Isn't this message about minimum number of > ISR's when *sending* messages? > Stacktrace: > org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup: > Messages are rejected since there are fewer in-sync replicas than required. > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupRequestHandler.handle(AbstractCoordinator.java:444) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupRequestHandler.handle(AbstractCoordinator.java:411) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:665) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:644) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:167) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.onComplete(ConsumerNetworkClient.java:380) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:274) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:222) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:311) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:890) > ~[kafka-clients-0.9.0.1.jar:na] > at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853) > ~[kafka-clients-0.9.0.1.jar:na] -- This message was sent by Atlassian JIRA (v6.3.4#6332)