OffsetRequest
Namespace: Kafunk
Parent Module: Protocol
A request to return offset information for a set of topics on a specific replica.
Record Fields
| Record Field | Description |
replicaId
Signature: ReplicaId
|
|
topics
Signature: (TopicName * (Partition * Time * MaxNumberOfOffsets) []) []
|
|
Constructors
| Constructor | Description |
new(replicaId, topics)
Signature: (replicaId:ReplicaId * topics:(TopicName * (Partition * Time * MaxNumberOfOffsets) []) []) -> OffsetRequest
|
CompiledName: |