The LastStableOffsetLag metric should be removed when partition is deleted
Author: Dong Lin
Reviewers: Ismael Juma
Closes from lindong28/KAFKA-5544
@@ -561,6 +561,7 @@ class Partition(val topic: String,
removeMetric("UnderReplicated", tags)
removeMetric("InSyncReplicasCount", tags)
removeMetric("ReplicasCount", tags)
+ removeMetric("LastStableOffsetLag", tags)
}
override def equals(that: Any): Boolean = that match {
