Class KafkaRoundRobinPartitionAssigner

Hierarchy

KafkaRoundRobinPartitionAssigner

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new KafkaRoundRobinPartitionAssigner(config: { cluster: Cluster }): KafkaRoundRobinPartitionAssigner

- Defined in packages/microservices/helpers/kafka-round-robin-partition-assigner.ts:16
Parameters
- config: { cluster: Cluster }
  - cluster: Cluster
Returns KafkaRoundRobinPartitionAssigner

Properties

Private Readonly config

config: { cluster: Cluster }

Type declaration

cluster: Cluster

Readonly name

name: "RoundRobinByTime" = "RoundRobinByTime"

Readonly version

version: 1 = 1

Methods

assign

assign(group: { members: GroupMember[]; topics: string[]; userData: Buffer }): Promise<GroupMemberAssignment[]>

- Defined in packages/microservices/helpers/kafka-round-robin-partition-assigner.ts:33
This process can result in imbalanced assignments

Parameters
- group: { members: GroupMember[]; topics: string[]; userData: Buffer }
  - members: GroupMember[]
  - topics: string[]
  - userData: Buffer
Returns Promise<GroupMemberAssignment[]>

object partitions per topic per member

getTime

getTime(): [number, number]

- Defined in packages/microservices/helpers/kafka-round-robin-partition-assigner.ts:95
Returns [number, number]

mapToTimeAndMemberId

mapToTimeAndMemberId(member: GroupMember): { memberId: string; time: any }

- Defined in packages/microservices/helpers/kafka-round-robin-partition-assigner.ts:99
Parameters
- member: GroupMember
Returns { memberId: string; time: any }
- memberId: string
- time: any

protocol

protocol(subscription: { topics: string[]; userData: Buffer }): GroupState

- Defined in packages/microservices/helpers/kafka-round-robin-partition-assigner.ts:77
Parameters
- subscription: { topics: string[]; userData: Buffer }
  - topics: string[]
  - userData: Buffer
Returns GroupState

sortByTime

sortByTime(a: Record<"time", number[]>, b: Record<"time", number[]>): number

- Defined in packages/microservices/helpers/kafka-round-robin-partition-assigner.ts:111
Parameters
- a: Record<"time", number[]>
- b: Record<"time", number[]>
Returns number

Generated using TypeDoc