[
https://issues.apache.org/jira/browse/KAFKA-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-3231.
--------------------------------
Resolution: Duplicate
Thanks for checking [~curtissallen].
> 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)
