[jira] [Commented] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset
[ https://issues.apache.org/jira/browse/KAFKA-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889127#comment-15889127 ] Vahid Hashemian commented on KAFKA-4095: [~jeffwidman] This JIRA applies to the old (ZooKeeper based) consumer, as you mentioned. But the old consumer is not yet deprecated yet. It is expected to officially become deprecated in the next release though ([KIP|https://cwiki.apache.org/confluence/display/KAFKA/KIP-109%3A+Old+Consumer+Deprecation]). > 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.15#6346)
[jira] [Commented] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset
[ https://issues.apache.org/jira/browse/KAFKA-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889093#comment-15889093 ] Jeff Widman commented on KAFKA-4095: Wasn't this solved by KAFKA-2000? At least for the new consumers which store their offsets in Kafka... if they store offsets in zookeeper that isn't updated, but that's been deprecated since Kafka 0.8.2 so probably not worth fixing at this point. > 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.15#6346)
[jira] [Commented] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset
[ https://issues.apache.org/jira/browse/KAFKA-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688291#comment-15688291 ] ASF GitHub Bot commented on KAFKA-4095: --- GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/2160 KAFKA-4095: Remove topic offsets and owners from ZK consumer groups upon topic deletion You can merge this pull request into a Git repository by running: $ git pull https://github.com/vahidhashemian/kafka KAFKA-4095 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2160.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2160 commit 953f4ccb5f6009c4198e1aadb4e0d5758299fdda Author: Vahid HashemianDate: 2016-11-22T23:25:41Z KAFKA-4095: Remove topic offsets and owners from ZK consumer groups upon topic deletion > 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)
[jira] [Commented] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset
[ https://issues.apache.org/jira/browse/KAFKA-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1544#comment-1544 ] Vahid Hashemian commented on KAFKA-4095: [~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=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)
[jira] [Commented] (KAFKA-4095) When a topic is deleted and then created with the same name, 'committed' offsets are not reset
[ https://issues.apache.org/jira/browse/KAFKA-4095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446292#comment-15446292 ] Vahid Hashemian commented on KAFKA-4095: I can take a look at this. > 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 > > 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)