kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "huxi (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper
Date Thu, 20 Oct 2016 07:28:58 GMT

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

huxi edited comment on KAFKA-4295 at 10/20/16 7:28 AM:
-------------------------------------------------------

The design is not changed. 0.9.x still removes the zk nodes for inactive console consumer
groups which used a randomly-generated group id. But if the consumer is stopped before the
zk node 'offsets' got created, the program failed to remove the path, which I prefer to think
is a bug.  


was (Author: huxi_2b):
The design is not changed. 0.9.x still removes the zk nodes for inactive console consumer
groups which used a randomly-generated group id. But if the consumer is stopped before the
zk node 'offsets' got created, the program failed to remove the path, which I prefer is a
bug.  

> kafka-console-consumer.sh does not delete the temporary group in zookeeper
> --------------------------------------------------------------------------
>
>                 Key: KAFKA-4295
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4295
>             Project: Kafka
>          Issue Type: Bug
>          Components: admin
>    Affects Versions: 0.9.0.1, 0.10.0.0, 0.10.0.1
>            Reporter: Sswater Shi
>            Assignee: huxi
>            Priority: Minor
>
> I'm not sure it is a bug or you guys designed it.
> Since 0.9.x.x, the kafka-console-consumer.sh will not delete the group information in
zookeeper/consumers on exit when without "--new-consumer". There will be a lot of abandoned
zookeeper/consumers/console-consumer-xxx if kafka-console-consumer.sh runs a lot of times.
> When 0.8.x.x,  the kafka-console-consumer.sh can be followed by an argument "group".
If not specified, the kafka-console-consumer.sh will create a temporary group name like 'console-consumer-xxxx'.
If the group name is specified by "group", the information in the zookeeper/consumers will
be kept on exit. If the group name is a temporary one, the information in the zookeeper will
be deleted when kafka-console-consumer.sh is quitted by Ctrl+C. Why this is changed from 0.9.x.x.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message