kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-5544; The LastStableOffsetLag metric should be removed when partition is deleted
Date Fri, 30 Jun 2017 05:47:36 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 5536b1237 -> a16475eb3


KAFKA-5544; The LastStableOffsetLag metric should be removed when partition is deleted

Author: Dong Lin <lindong28@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #3463 from lindong28/KAFKA-5544


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a16475eb
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a16475eb
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a16475eb

Branch: refs/heads/trunk
Commit: a16475eb333b0205b74b817237cba187862e61e7
Parents: 5536b12
Author: Dong Lin <lindong28@gmail.com>
Authored: Fri Jun 30 06:47:32 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Fri Jun 30 06:47:32 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/a16475eb/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 {


Mime
View raw message