Lease Class

Lease contains partition processing state metadata used to manage partition state.

Constructor

Lease()

increment_epoch	Increment lease epoch.
is_expired	Determines whether the lease is expired. By default lease never expires. Deriving class implements the lease expiry logic.
with_partition_id	Init with partition Id.
with_source	Init with existing lease.

Increment lease epoch.

increment_epoch()

Determines whether the lease is expired. By default lease never expires. Deriving class implements the lease expiry logic.

async is_expired()

bool

Init with partition Id.

with_partition_id(partition_id)

Required

ID of a given partition.

Init with existing lease.

with_source(lease)

Required

An existing Lease.