[
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)
