[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062369#comment-15062369 ]
Ismael Juma commented on KAFKA-2000: ------------------------------------ Looks like it is, `GroupMetadataManager` has the following code: {code} val expiredOffsets = offsetsCache.filter { case (groupTopicPartition, offsetAndMetadata) => offsetAndMetadata.expireTimestamp < startMs } {code} [~harsha_ch], do you want to submit a PR with this change? > Delete consumer offsets from kafka once the topic is deleted > ------------------------------------------------------------ > > Key: KAFKA-2000 > URL: https://issues.apache.org/jira/browse/KAFKA-2000 > Project: Kafka > Issue Type: Bug > Reporter: Sriharsha Chintalapani > Assignee: Sriharsha Chintalapani > Labels: newbie++ > Fix For: 0.9.1.0 > > Attachments: KAFKA-2000.patch, KAFKA-2000_2015-05-03_10:39:11.patch > > -- This message was sent by Atlassian JIRA (v6.3.4#6332)