GroupCoordinatorRequest
Namespace: Kafunk
Parent Module: Protocol
The offsets for a given consumer group are maintained by a specific broker called the group coordinator. i.e., a consumer needs to issue its offset commit and fetch requests to this specific broker. It can discover the current coordinator by issuing a group coordinator request. Can be routed to any node in the bootstrap list.
Record Fields
| Record Field | Description |
coordinatorType
Signature: int8
|
|
groupId
Signature: GroupId
|
|
Constructors
| Constructor | Description |
new(groupId, coordinatorType)
Signature: (groupId:GroupId * coordinatorType:int8) -> GroupCoordinatorRequest
|
CompiledName: |
new(groupId)
Signature: groupId:GroupId -> GroupCoordinatorRequest
|
CompiledName: |
