[
https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14066613#comment-14066613
]
Guozhang Wang commented on KAFKA-1476:
--------------------------------------
1. List groups: return the list of group ids.
2. List groups (topic_name): return the list of group ids at least one member
of which is consuming the topic.
3. Describe group (group_id): return the current generation id, members of the
group (consumer_ids), subscribed topics or topic/partitions of each consumer,
and their current offsets.
4. Set group consumption offset (consumer_id, generation_id, [partition,
offset]): set the offsets of the consumed partitions for a given consumer, and
the right generation id.
1) would work with ZK only, 2) requires ZK and the coordinator, 3) and 4)
requires coordinator only.
Also 3) would potentially replace the current ConsumerOffsetChecker.
> Get a list of consumer groups
> -----------------------------
>
> Key: KAFKA-1476
> URL: https://issues.apache.org/jira/browse/KAFKA-1476
> Project: Kafka
> Issue Type: Wish
> Components: tools
> Affects Versions: 0.8.1.1
> Reporter: Ryan Williams
> Labels: newbie
> Fix For: 0.9.0
>
> Attachments: KAFKA-1476.patch
>
>
> It would be useful to have a way to get a list of consumer groups currently
> active via some tool/script that ships with kafka. This would be helpful so
> that the system tools can be explored more easily.
> For example, when running the ConsumerOffsetChecker, it requires a group
> option
> bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic test --group
> ?
> But, when just getting started with kafka, using the console producer and
> consumer, it is not clear what value to use for the group option. If a list
> of consumer groups could be listed, then it would be clear what value to use.
> Background:
> http://mail-archives.apache.org/mod_mbox/kafka-users/201405.mbox/%3cCAOq_b1w=slze5jrnakxvak0gu9ctdkpazak1g4dygvqzbsg...@mail.gmail.com%3e
--
This message was sent by Atlassian JIRA
(v6.2#6252)
