[
https://issues.apache.org/jira/browse/KAFKA-4349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15609549#comment-15609549
]
ASF GitHub Bot commented on KAFKA-4349:
---------------------------------------
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2070
KAFKA-4349: Handle 'PreparingRebalance' state in consumer group describe
The edge case where consumer group state is `PreparingRebalance` will be
explicitly handled as the group assignment is not yet determined.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA-4349
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2070.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2070
----
commit 14ba72280aa83a8fa062aab543bbbbf34f1f4411
Author: Vahid Hashemian <[email protected]>
Date: 2016-10-26T20:01:26Z
KAFKA-4349: Handle 'PreparingRebalance' state in consumer group describe
The edge case where consumer group state is `PreparingRebalance` will be
explicitly handled as the group assignment is not yet determined.
----
> Consumer group describe exception when group state is PreparingRebalance
> ------------------------------------------------------------------------
>
> Key: KAFKA-4349
> URL: https://issues.apache.org/jira/browse/KAFKA-4349
> Project: Kafka
> Issue Type: Bug
> Reporter: Vahid Hashemian
> Assignee: Vahid Hashemian
>
> When the group state is {{PreparingRebalance}} the consumer group describe
> raises the following exception:
> {code}
> Error: Executing consumer group command failed due to Error reading field
> 'version': java.nio.BufferUnderflowException
> org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73)
> org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:106)
> kafka.admin.AdminClient$$anonfun$1.apply(AdminClient.scala:155)
> kafka.admin.AdminClient$$anonfun$1.apply(AdminClient.scala:154)
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> scala.collection.Iterator$class.foreach(Iterator.scala:727)
> scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
> scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
> scala.collection.AbstractTraversable.map(Traversable.scala:105)
> kafka.admin.AdminClient.describeConsumerGroup(AdminClient.scala:154)
> kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.collectGroupAssignment(ConsumerGroupCommand.scala:391)
> kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describeGroup(ConsumerGroupCommand.scala:139)
> kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:379)
> kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:70)
> kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
> {code}
> The exception is a side-effect of the fix for KAFKA-3144 that misses handling
> this edge case.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
