FetchResponse
Namespace: Kafunk
Parent Module: Protocol
Record Fields
| Record Field | Description |
throttleTime
Signature: ThrottleTime
|
|
topics
Signature: (TopicName * (Partition * ErrorCode * HighwaterMarkOffset * LastStableOffset * LogStartOffset * AbortedTransaction [] * MessageSetSize * MessageSet) []) []
|
|
Constructors
| Constructor | Description |
new(tt, topics)
Signature: (tt:ThrottleTime * topics:(TopicName * (Partition * ErrorCode * HighwaterMarkOffset * LastStableOffset * LogStartOffset * AbortedTransaction [] * MessageSetSize * MessageSet) []) []) -> FetchResponse
|
CompiledName: |
