You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "huxi (JIRA)" <ji...@apache.org> on 2016/10/19 13:10:58 UTC

[jira] [Commented] (KAFKA-4295) kafka-console-consumer.sh does not delete the temporary group in zookeeper

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

huxi commented on KAFKA-4295:
-----------------------------

I think we'd better follow what 0.8.x does for us.  Removed consumer group's persisitent nodes after it became inactive in case of polluting zookeeper, if we did not specify "group.id" for the console consumer.

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