[
https://issues.apache.org/jira/browse/KAFKA-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15143005#comment-15143005
]
Curtis Allen commented on KAFKA-3231:
-------------------------------------
Using https://github.com/Shopify/sarama via
https://github.com/bsm/sarama-cluster
Using a simple command line client
(https://github.com/bsm/sarama-cluster/blob/master/cmd/sarama-cluster-cli/main.go),
the offsets seem to be persisted because I can the following messages in the
kafka log
{code}
[2016-02-11 08:34:53,771] INFO [Group Metadata Manager on Broker 0]: Finished
loading offsets from [__consumer_offsets,47] in 6 milliseconds.
(kafka.coordinator.GroupMetadataManager)
[2016-02-11 08:34:53,771] INFO [Group Metadata Manager on Broker 0]: Loading
offsets and group metadata from [__consumer_offsets,4]
(kafka.coordinator.GroupMetadataManager)
[2016-02-11 08:34:53,778] INFO [Group Metadata Manager on Broker 0]: Finished
loading offsets from [__consumer_offsets,4] in 7 milliseconds.
(kafka.coordinator.GroupMetadataManager)
{code}
Started the client using
{code}
go run cmd/sarama-cluster-cli/main.go -brokers=127.0.0.1:9092 -group=testgroup
-offset=oldest -topics=test -verbose=true
{code}
> 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)
