[jira] [Created] (KAFKA-5110) ConsumerGroupCommand error handling improvement

[Dustin Cote (JIRA)]

Dustin Cote created KAFKA-5110:
----------------------------------

             Summary: ConsumerGroupCommand error handling improvement
                 Key: KAFKA-5110
                 URL: https://issues.apache.org/jira/browse/KAFKA-5110
             Project: Kafka
          Issue Type: Bug
          Components: tools
    Affects Versions: 0.10.1.1
            Reporter: Dustin Cote
            Assignee: Jason Gustafson


The ConsumerGroupCommand isn't handling partition errors properly. It throws 
the following:

{code}
kafka-consumer-groups.sh --zookeeper 10.10.10.10:2181 --group mygroup --describe

GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG OWNER

Error while executing consumer group command empty.head

java.lang.UnsupportedOperationException: empty.head

at scala.collection.immutable.Vector.head(Vector.scala:193)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService$$anonfun$getLogEndOffset$1.apply(ConsumerGroupCommand.scala:197)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService$$anonfun$getLogEndOffset$1.apply(ConsumerGroupCommand.scala:194)

at scala.Option.map(Option.scala:146)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService.getLogEndOffset(ConsumerGroupCommand.scala:194)

at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.kafka$admin$ConsumerGroupCommand$ConsumerGroupService$$describePartition(ConsumerGroupCommand.scala:125)

at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService$$anonfun$describeTopicPartition$2.apply(ConsumerGroupCommand.scala:107)

at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService$$anonfun$describeTopicPartition$2.apply(ConsumerGroupCommand.scala:106)

at 
scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)

at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)

at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describeTopicPartition(ConsumerGroupCommand.scala:106)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService.describeTopicPartition(ConsumerGroupCommand.scala:134)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService.kafka$admin$ConsumerGroupCommand$ZkConsumerGroupService$$describeTopic(ConsumerGroupCommand.scala:181)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService$$anonfun$describeGroup$1.apply(ConsumerGroupCommand.scala:166)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService$$anonfun$describeGroup$1.apply(ConsumerGroupCommand.scala:166)

at scala.collection.Iterator$class.foreach(Iterator.scala:893)

at scala.collection.AbstractIterator.foreach(Iterator.scala:1336)

at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)

at scala.collection.AbstractIterable.foreach(Iterable.scala:54)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:166)

at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describe(ConsumerGroupCommand.scala:89)

at 
kafka.admin.ConsumerGroupCommand$ZkConsumerGroupService.describe(ConsumerGroupCommand.scala:134)

at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:68)

at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
{code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)