[jira] [Created] (KAFKA-2768) New-consumer sends invalid describeGroupResponse while restabilizing

[Ashish K Singh (JIRA)]

Ashish K Singh created KAFKA-2768:
-------------------------------------

             Summary: New-consumer sends invalid describeGroupResponse while 
restabilizing
                 Key: KAFKA-2768
                 URL: https://issues.apache.org/jira/browse/KAFKA-2768
             Project: Kafka
          Issue Type: Bug
          Components: consumer
            Reporter: Ashish K Singh
            Assignee: Ashish K Singh


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

{code}
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)
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)