Repository: kafka Updated Branches: refs/heads/0.11.0 1d27ca822 -> 87658b9b1
KAFKA-5544; The LastStableOffsetLag metric should be removed when partition is deleted Author: Dong Lin <lindon...@gmail.com> Reviewers: Ismael Juma <ism...@juma.me.uk> Closes #3463 from lindong28/KAFKA-5544 (cherry picked from commit a16475eb333b0205b74b817237cba187862e61e7) Signed-off-by: Ismael Juma <ism...@juma.me.uk> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/87658b9b Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/87658b9b Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/87658b9b Branch: refs/heads/0.11.0 Commit: 87658b9b155354426011e35d4838c31b629e5318 Parents: 1d27ca8 Author: Dong Lin <lindon...@gmail.com> Authored: Fri Jun 30 06:47:32 2017 +0100 Committer: Ismael Juma <ism...@juma.me.uk> Committed: Fri Jun 30 06:47:42 2017 +0100 ---------------------------------------------------------------------- core/src/main/scala/kafka/cluster/Partition.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/87658b9b/core/src/main/scala/kafka/cluster/Partition.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/cluster/Partition.scala b/core/src/main/scala/kafka/cluster/Partition.scala index 32b6865..ebf3140 100755 --- a/core/src/main/scala/kafka/cluster/Partition.scala +++ b/core/src/main/scala/kafka/cluster/Partition.scala @@ -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 {
