kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-4349) Consumer group describe exception when group state is PreparingRebalance
Date Thu, 27 Oct 2016 06:32:58 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-4349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15610884#comment-15610884
] 

ASF GitHub Bot commented on KAFKA-4349:
---------------------------------------

GitHub user vahidhashemian reopened a pull request:

    https://github.com/apache/kafka/pull/2070

    KAFKA-4349: Handle 'PreparingRebalance' and 'AwaitingSync' states in consumer group describe

    The edge case where consumer group state is `PreparingRebalance` or `AwaitingSync` 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 81e1273b62d2d43796573a9158da79e445cb5b8c
Author: Vahid Hashemian <vahidhashemian@us.ibm.com>
Date:   2016-10-26T20:01:26Z

    KAFKA-4349: Handle 'PreparingRebalance' and 'AwaitingSync' state in consumer group describe
    
    The edge case where consumer group state is `PreparingRebalance` or `AwaitingSync` 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)

Mime
View raw message