Class GreedyPartitionLoadBalancer

Package version

This class does no load balancing - it's intended to be used when you want to avoid load balancing and consume a set of partitions (or all available partitions)

Hierarchy

GreedyPartitionLoadBalancer

Implements

PartitionLoadBalancer

Index

Constructors

constructor

Methods

loadBalance

Constructors

constructor

new GreedyPartitionLoadBalancer(partitionIds?: string[]): GreedyPartitionLoadBalancer

- Defined in partitionLoadBalancer.ts:31
Parameters
- Optional partitionIds: string[]
  
  An optional set of partition IDs. undefined means all partitions.
Returns GreedyPartitionLoadBalancer

Methods

loadBalance

loadBalance(partitionOwnershipMap: Map<string, PartitionOwnership>, partitionsToAdd: string[]): string[]

Implementation of PartitionLoadBalancer.loadBalance
- Defined in partitionLoadBalancer.ts:41
Parameters
- partitionOwnershipMap: Map<string, PartitionOwnership>
- partitionsToAdd: string[]
Returns string[]

Generated using TypeDoc