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 00d38911..b9fdb853 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 @@ -124,10 +124,7 @@ public final class LeaseAssignmentManager { // so reset the flag to refresh the state before processing during a restart of LAM. tookOverLeadershipInThisRun = false; managerFuture = executorService.scheduleWithFixedDelay( - this::performAssignment, - 0L, - (int) (leaseAssignmentIntervalMillis), - TimeUnit.MILLISECONDS); + this::performAssignment, 0L, (int) (leaseAssignmentIntervalMillis), TimeUnit.MILLISECONDS); log.info("Started LeaseAssignmentManager"); return; }