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:46 GMT
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 <lindong28@gmail.com>

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

Closes #3463 from lindong28/KAFKA-5544

(cherry picked from commit a16475eb333b0205b74b817237cba187862e61e7)
Signed-off-by: Ismael Juma <ismael@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 <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: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 {


Mime
View raw message