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