[jira] [Created] (KAFKA-3231) describe group IllegalArgumentException for kafka-consumer-groups

[Curtis Allen (JIRA)]

Curtis Allen created KAFKA-3231:
-----------------------------------

             Summary: describe group IllegalArgumentException for 
kafka-consumer-groups
                 Key: KAFKA-3231
                 URL: https://issues.apache.org/jira/browse/KAFKA-3231
             Project: Kafka
          Issue Type: Bug
          Components: consumer
    Affects Versions: 0.9.0.0
            Reporter: Curtis Allen
            Assignee: Neha Narkhede
            Priority: Minor


The kafka-consumer-groups tool doesn't seem to work when describing new 
consumer groups. 

Listing groups work
{code}
$ ./bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 
127.0.0.1:9092 --list
testgroup
{code}

Describing throws an exception
{code}
$ ./kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 
--describe --group testgroup
Error while executing consumer group command Error reading field 'user_data': 
java.lang.IllegalArgumentException
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 
'user_data': java.lang.IllegalArgumentException
        at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:71)
        at 
org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:109)
        at 
kafka.admin.AdminClient$$anonfun$describeConsumerGroup$1.apply(AdminClient.scala:165)
        at 
kafka.admin.AdminClient$$anonfun$describeConsumerGroup$1.apply(AdminClient.scala:164)
        at scala.collection.immutable.List.map(List.scala:273)
        at kafka.admin.AdminClient.describeConsumerGroup(AdminClient.scala:164)
        at 
kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:314)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describe(ConsumerGroupCommand.scala:84)
        at 
kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describe(ConsumerGroupCommand.scala:302)
        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)