From 443b41690b59e9bf487ba28d3590503771d36c34 Mon Sep 17 00:00:00 2001 From: eha sah Date: Fri, 11 Apr 2025 15:21:10 -0700 Subject: [PATCH] Code for backward compatibility check --- .../coordinator/assignment/LeaseAssignmentManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java index 5708ac13..4da06626 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java @@ -71,21 +71,21 @@ import static java.util.Objects.nonNull; */ @Slf4j @KinesisClientInternalApi -public class LeaseAssignmentManager { +public final class LeaseAssignmentManager { /** * Default number of continuous failure execution after which leadership is released. */ private static final int DEFAULT_FAILURE_COUNT_TO_SWITCH_LEADER = 3; - private static final String FORCE_LEADER_RELEASE_METRIC_NAME = "ForceLeaderRelease"; - /** * Default multiplier for LAM frequency with respect to leaseDurationMillis (lease failover millis). * If leaseDurationMillis is 10000 millis, default LAM frequency is 20000 millis. */ private static final int DEFAULT_LEASE_ASSIGNMENT_MANAGER_FREQ_MULTIPLIER = 2; + private static final String FORCE_LEADER_RELEASE_METRIC_NAME = "ForceLeaderRelease"; + /** * Default retry attempt for loading leases and workers before giving up. */