[jira] [Commented] (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=16053311#comment-16053311 ] Ivan Babrou commented on KAFKA-5348: [~vahid], there is no /ids, only /offsets, that is the point. > 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)
[jira] [Commented] (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=16054545#comment-16054545 ] Vahid Hashemian commented on KAFKA-5348: [~bobrik] Then perhaps ZooKeeper data for this group is somehow corrupted?! Because normally, even if all consumers in the group die the {{/ids}} path would still be there. Is this something that you can easily reproduce? > 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)
[jira] [Commented] (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=16061802#comment-16061802 ] Ivan Babrou commented on KAFKA-5348: I don't know how to reproduce, unfortunately. Is there a reason to check for /ids on group removal? Why not just remove if there are no active partition owners? > 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)