From 3ba8a1033d1b5c3e08649a3af5160a44541cdd59 Mon Sep 17 00:00:00 2001 From: Sriharsha Chintalapani Date: Mon, 30 Mar 2015 14:45:30 -0700 Subject: [PATCH] KAFKA-2000. Delete consumer offsets from kafka once the topic is deleted. --- core/src/main/scala/kafka/server/OffsetManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/server/OffsetManager.scala b/core/src/main/scala/kafka/server/OffsetManager.scala index 395b1db..daa9ee8 100644 --- a/core/src/main/scala/kafka/server/OffsetManager.scala +++ b/core/src/main/scala/kafka/server/OffsetManager.scala @@ -121,7 +121,7 @@ class OffsetManager(val config: OffsetManagerConfig, val startMs = SystemTime.milliseconds val staleOffsets = offsetsCache.filter { case (groupTopicPartition, offsetAndMetadata) => - offsetAndMetadata.expireTimestamp < startMs + offsetAndMetadata.expireTimestamp < startMs || !metadataCache.contains(groupTopicPartition.topicPartition.topic) } debug("Found %d expired offsets.".format(staleOffsets.size)) -- 1.9.5 (Apple Git-50.3)