You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Xiaoju Wu (JIRA)" <ji...@apache.org> on 2017/06/28 12:45:03 UTC

[jira] [Commented] (KAFKA-4047) Return more useful information from ConsumerGroupCommand for consumer groups that are rebalancing or manually assigned

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

Xiaoju Wu commented on KAFKA-4047:
----------------------------------

[~vahid] With the patch in KAFKA-3853, are information of consumer groups that are manually assigned returned?

> Return more useful information from ConsumerGroupCommand for consumer groups that are rebalancing or manually assigned
> ----------------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-4047
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4047
>             Project: Kafka
>          Issue Type: Improvement
>          Components: consumer, tools
>    Affects Versions: 0.9.0.1, 0.10.0.0, 0.10.0.1
>            Reporter: Sean McKibben
>            Priority: Minor
>
> For consumers which are manually assigned topic partitions, or for offsets which are otherwise manually committed to brokers using the new consumer API, the existing ConsumerGroupCommand tools are operationally insufficient.
> There are many use cases in production operation when it is important to be able to easily retrieve the stored offsets and calculated lag of a consumer group, even if the group is rebalancing or partition assignment information is indeterminate. Often these cases involve a misbehaving or crashed client application, and having the ConsumerGroupCommand return {{Consumer group `myGroupID` does not exist or is rebalancing.}} instead of the information it does know is not very helpful. Additionally, when manual offset commits are used, or the automatic consumer group subscription management is not used, the same message is returned by the tool. In these cases, the offsets are actually stored and available even though the broker/coordinator doesn't have information about partition ownership.
> Previously, this was a non-issue as a ZK client could be leveraged relatively easily to get important information like the last stored offset positions, or consumer-offset-checker would return more information in its responses. With the new consumer, however, the process for getting offset and lag is not as straightforward, and tools to provide this information at the operational level are necessary as part of a Kafka installation.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)