[ https://issues.apache.org/jira/browse/KAFKA-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16565753#comment-16565753 ]
Sriharsha Chintalapani commented on KAFKA-6868: ----------------------------------------------- [~hachikuji] can we include this into 1.1 branch. This is a critical fix affecting the clients from 0.10 onwards to query group offset info. If we are planning on doing a future 1.1.x release we should include this Jira as well. > BufferUnderflowException in client when querying consumer group information > --------------------------------------------------------------------------- > > Key: KAFKA-6868 > URL: https://issues.apache.org/jira/browse/KAFKA-6868 > Project: Kafka > Issue Type: Bug > Reporter: Xavier Léauté > Assignee: Colin P. McCabe > Priority: Blocker > > Exceptions get thrown when describing consumer group or querying group > offsets from a 1.0 cluster > Stacktrace is a result of calling > {{AdminClient.describeConsumerGroups(Collection<String> > groupIds).describedGroups().entrySet()}} followed by > {{KafkaFuture<ConsumerGroupDescription>.whenComplete()}} > {code} > java.util.concurrent.ExecutionException: > org.apache.kafka.common.protocol.types.SchemaException: Error reading field > 'version': java.nio.BufferUnderflowException > at > org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45) > at > org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32) > at > org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:104) > at > org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:274) > at > [snip] > Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error > reading field 'version': java.nio.BufferUnderflowException > at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:76) > at > org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:105) > at > org.apache.kafka.clients.admin.KafkaAdminClient$21$1.handleResponse(KafkaAdminClient.java:2307) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.handleResponses(KafkaAdminClient.java:960) > at > org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1045) > ... 1 more > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)