FetchRequest
Namespace: Kafunk
Parent Module: Protocol
Record Fields
| Record Field | Description |
isolationLevel
Signature: IsolationLevel
|
|
maxBytes
Signature: MaxBytes
|
|
maxWaitTime
Signature: MaxWaitTime
|
|
minBytes
Signature: MinBytes
|
|
replicaId
Signature: ReplicaId
|
|
topics
Signature: (TopicName * (Partition * FetchOffset * LogStartOffset * MaxBytes) []) []
|
|
Constructors
| Constructor | Description |
new(...)
Signature: (replicaId:ReplicaId * maxWaitTime:MaxWaitTime * minBytes:MinBytes * topics:(TopicName * (Partition * FetchOffset * LogStartOffset * MaxBytes) []) [] * maxBytes:MaxBytes * isolationLevel:IsolationLevel) -> FetchRequest
|
CompiledName: |
