From a344ee4d05d19d4786a7a4d5d5062adcc080a8c0 Mon Sep 17 00:00:00 2001 From: Adam Tapp Date: Wed, 30 Mar 2022 16:14:11 -0500 Subject: [PATCH] Added metric to record when a lease cannot be taken due to a ConditionalCheckFailedException --- .../amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java | 1 + 1 file changed, 1 insertion(+) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java index 365b1cbaf..a90ef56e0 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java @@ -236,6 +236,7 @@ synchronized Map takeLeases(Callable timeProvider) } scope.addData("TakenLeases", takenLeases.size(), StandardUnit.COUNT, MetricsLevel.SUMMARY); + scope.addData("UntakenLeases", untakenLeaseKeys.size(), StandardUnit.COUNT, MetricsLevel.SUMMARY); } finally { MetricsUtil.endScope(scope); }