software.amazon.kinesis.coordinator.assignment

Class LeaseCountBasedLeaseAssignmentDecider

java.lang.Object

software.amazon.kinesis.coordinator.assignment.LeaseCountBasedLeaseAssignmentDecider

All Implemented Interfaces:

LeaseAssignmentDecider

public final class LeaseCountBasedLeaseAssignmentDecider
extends Object
implements LeaseAssignmentDecider

A lease assignment decider that distributes leases based on lease count balancing. This implementation ensures fair distribution of leases across workers by:

• Assigning expired/unassigned leases to workers with the fewest current leases
• Balancing lease distribution to minimize variance between workers
• Respecting the maximum lease limit per worker

Constructor Summary

Constructors

Constructor and Description
LeaseCountBasedLeaseAssignmentDecider()

Method Summary

Modifier and Type	Method and Description
void	assignExpiredOrUnassignedLeases(List<Lease> expiredOrUnAssignedLeases) Assigns expired or unassigned leases to workers with the fewest current leases.
void	balanceWorkerVariance() Balances lease distribution across workers to minimize variance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LeaseCountBasedLeaseAssignmentDecider

public LeaseCountBasedLeaseAssignmentDecider()

Method Detail

assignExpiredOrUnassignedLeases

public void assignExpiredOrUnassignedLeases(List<Lease> expiredOrUnAssignedLeases)

Assigns expired or unassigned leases to workers with the fewest current leases. Leases are sorted by lastCounterIncrementNanos to ensure consistent assignment order.

Specified by:

assignExpiredOrUnassignedLeases in interface LeaseAssignmentDecider

Parameters:

expiredOrUnAssignedLeases - list of leases that need to be assigned to workers

balanceWorkerVariance

public void balanceWorkerVariance()

Balances lease distribution across workers to minimize variance. Avoids stealing leases that are pending handoff to prevent disruption.

Specified by:

balanceWorkerVariance in interface LeaseAssignmentDecider