[KAFKA-6868] BufferUnderflowException in client when querying consumer group information

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Assignee: Colin McCabe
• Reporter: Xavier Léauté
• Created: 04/May/18 23:12
• Updated: 01/Aug/18 18:13
• Resolved: 21/May/18 15:38

Description

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()

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

Issue Links

• links to: GitHub Pull Request #4980