[KAFKA-2768] New-consumer sends invalid describeGroupResponse while restabilizing

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.9.0.0
• Component/s: consumer
• Assignee: Ashish Singh
• Reporter: Ashish Singh
• Reviewer: Guozhang Wang
• Created: 06/Nov/15 22:33
• Updated: 13/Nov/15 20:50
• Resolved: 13/Nov/15 20:50

Description

While a consumer group is restabilizing, it sends describeGroupResponse with no error, but empty metadata and assignments. That leads to SchemaException on client.

Error while executing consumer group command Error reading field 'version': java.nio.BufferUnderflowException
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:73)
	at org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:106)
	at kafka.admin.AdminClient$$anonfun$describeConsumerGroup$1.apply(AdminClient.scala:163)
	at kafka.admin.AdminClient$$anonfun$describeConsumerGroup$1.apply(AdminClient.scala:161)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.immutable.List.foreach(List.scala:318)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
	at scala.collection.AbstractTraversable.map(Traversable.scala:105)
	at kafka.admin.AdminClient.describeConsumerGroup(AdminClient.scala:161)
	at kafka.admin.ConsumerGroupCommand$.describe(ConsumerGroupCommand.scala:109)
	at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:63)
	at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)