You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Vahid Hashemian (JIRA)" <ji...@apache.org> on 2017/06/13 22:37:02 UTC

[jira] [Comment Edited] (KAFKA-5348) kafka-consumer-groups.sh refuses to remove groups without ids

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

Vahid Hashemian edited comment on KAFKA-5348 at 6/13/17 10:36 PM:
------------------------------------------------------------------

[~bobrik] In the scenario you described I assume some consumer id exists under the {{/ids}} path. By design, the consumer group (for old consumers) can be deleted only if there is no active consumer in the group. There are active consumers group in the group iff the path {{/ids}} exists for this group and there are consumer ids inside this path. If this is not what you're experiencing please advise and perhaps provide steps to reproduce. Thanks.



was (Author: vahid):
[~bobrik] In the scenario you described I assume some consumer id exists under the {{/ids}} path. By design, the consumer group (for old consumers) can be deleted only if there is no active consumer in the group. There is no active consumer group in the group iff the path {{/ids}} exists for this group and there are consumer ids inside this path. If this is not what you're experiencing please advise and perhaps provide steps to reproduce. Thanks.


> kafka-consumer-groups.sh refuses to remove groups without ids
> -------------------------------------------------------------
>
>                 Key: KAFKA-5348
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5348
>             Project: Kafka
>          Issue Type: Bug
>          Components: admin
>    Affects Versions: 0.10.2.0
>            Reporter: Ivan Babrou
>            Assignee: Vahid Hashemian
>
> In zookeeper I have:
> {noformat}
> [zk: foo(CONNECTED) 37] ls /kafka/logs/consumers/console-consumer-4107
> [offsets]
> {noformat}
> This consumer group also shows up when I list consumer groups:
> {noformat}
> $ /usr/local/kafka/bin/kafka-consumer-groups.sh --zookeeper foo:2181/kafka/logs --list | fgrep console-consumer-4107
> Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API).
> console-consumer-4107
> {noformat}
> But I cannot remove this group:
> {noformat}
> $ /usr/local/kafka/bin/kafka-consumer-groups.sh --zookeeper 36zk1.in.pdx.cfdata.org:2181/kafka/logs --delete --group console-consumer-4107
> Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API).
> Error: Delete for group 'console-consumer-4107' failed because group does not exist.
> {noformat}
> I ran tcpdump and it turns out that /ids path is checked:
> {noformat}
> $.e.........P.fP...&......<...........//kafka/logs/consumers/console-consumer-4107/ids.
> {noformat}
> I think kafka should not check for /ids, it should check for / instead here.



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