[
https://issues.apache.org/jira/browse/KAFKA-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15332660#comment-15332660
]
Guozhang Wang commented on KAFKA-3059:
--------------------------------------
Chiming in here since Streams may need this feature as well for cleaning up (cc
[~mjsax]): I think "all consumers in the group is shutdown" is a reasonable
request before using this admin command. And in addition there are cases where
users only use Kafka for storing offsets but not for group management; so the
validation on the server side would be: "if there is no group registry
information, or else if the group's member list is empty, proceed".
For overriding offsets I agree that the current OffsetCommit Request with
generation id equals to -1 would work. As for DeleteGroup v.s. DeleteOffsets
for deleting offsets, personally I feel the latter may be necessary since there
are cases when users only want to delete some specific offset (but not all
offsets), and delete-group will not naturally support that. In addition, if
users really want to delete the whole group before waiting it to be auto purged
(with default purging frequency of 5 minutes today) they can still use
delete-offsets on all offsets.
One orthogonal point is that today we do not enforce "groupId" as required
config and default value is empty string, so that if two consumers started with
manual assignment but both forgot to set the group id their overrides will
interfere each other; one possible solution maybe to use "threadId" instead of
empty string as defaults, since for cases where users do not care to specify a
group id, they are usually just one instance starting on a single machine.
> ConsumerGroupCommand should allow resetting offsets for consumer groups
> -----------------------------------------------------------------------
>
> Key: KAFKA-3059
> URL: https://issues.apache.org/jira/browse/KAFKA-3059
> Project: Kafka
> Issue Type: Bug
> Reporter: Gwen Shapira
> Assignee: Jason Gustafson
>
> As discussed here:
> http://mail-archives.apache.org/mod_mbox/kafka-users/201601.mbox/%3CCA%2BndhHpf3ib%3Ddsh9zvtfVjRiUjSz%2B%3D8umXm4myW%2BpBsbTYATAQ%40mail.gmail.com%3E
> * Given a consumer group, remove all stored offsets
> * Given a group and a topic, remove offset for group and topic
> * Given a group, topic, partition and offset - set the offset for the
> specified partition and group with the given value
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
