[
https://issues.apache.org/jira/browse/KAFKA-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15449999#comment-15449999
]
Vahid Hashemian edited comment on KAFKA-4095 at 8/30/16 8:13 PM:
-----------------------------------------------------------------
[~glikson] Consumer group information is not removed if there is offset
information stored in it. There are some related open JIRAs that aim at
improving the information provided by the consumer group command (part of which
is showing stored offset information even if a consumer group has no active
member):
[KAFKA-3144|https://issues.apache.org/jira/browse/KAFKA-3144?focusedCommentId=15115594&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-15115594],
[KAFKA-3853|https://issues.apache.org/jira/browse/KAFKA-3853].
I agree that if a topic is deleted its stored offset info should be removed
from all consumer groups. This is something that currently doesn't seem to be
handled, and that's why you see this behavior. I'll look further into this.
was (Author: vahid):
[~glikson] I believe what you are observing is the intended behavior. Consumer
group information is not removed if there is offset information stored in it.
There are some related open JIRAs that aim at improving the information
provided by the consumer group command (part of which is showing stored offset
information even if a consumer group has no active member):
[KAFKA-3144|https://issues.apache.org/jira/browse/KAFKA-3144?focusedCommentId=15115594&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-15115594],
[KAFKA-3853|https://issues.apache.org/jira/browse/KAFKA-3853].
> When a topic is deleted and then created with the same name, 'committed'
> offsets are not reset
> ----------------------------------------------------------------------------------------------
>
> Key: KAFKA-4095
> URL: https://issues.apache.org/jira/browse/KAFKA-4095
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Affects Versions: 0.9.0.1, 0.10.0.0
> Reporter: Alex Glikson
> Assignee: Vahid Hashemian
>
> I encountered a very strange behavior of Kafka, which seems to be a bug.
> After deleting a topic and re-creating it with the same name, I produced
> certain amount of new messages, and then opened a consumer with the same ID
> that I used before re-creating the topic (with auto.commit=false,
> auto.offset.reset=earliest). While the latest offsets seemed up to date, the
> *committed* offset (returned by committed() method) was an *old* offset, from
> the time before the topic has been deleted and created.
> I would have assumed that when a topic is deleted, all the associated
> topic-partitions and consumer groups are recycled too.
> I am using the Java client version 0.9, with Kafka server 0.10.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
