fix(core): remove offset metrics when expired (#2021)

Signed-off-by: Shichao Nie <[email protected]>
AutoMQ · Sep 12, 2024 · af64a71 · af64a71
1 parent f5bb7b9
commit af64a71
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala b/core/src/main/scala/kafka/coordinator/group/GroupMetadata.scala
@@ -846,6 +846,7 @@ private[group] class GroupMetadata(val groupId: String, initialState: GroupState
       debug(s"Expired offsets from group '$groupId': ${expiredOffsets.keySet}")
 
     offsets --= expiredOffsets.keySet
+    expiredOffsets.keySet.foreach(removeOffsetMetric)
     expiredOffsets
   }