OffsetFetchRequest
Namespace: Kafunk
Parent Module: Protocol
Record Fields
| Record Field | Description |
consumerGroup
Signature: ConsumerGroup
|
|
topics
Signature: (TopicName * Partition []) []
|
|
Constructors
| Constructor | Description |
new(consumerGroup, topics)
Signature: (consumerGroup:ConsumerGroup * topics:(TopicName * Partition []) []) -> OffsetFetchRequest
|
CompiledName: |