Safe Haskell | Safe-Inferred |
---|---|
Language | Haskell2010 |
Synopsis
- data Request = Request {
- replicaId :: !Int32
- maxWaitMilliseconds :: !Int32
- minBytes :: !Int32
- maxBytes :: !Int32
- isolationLevel :: !Int8
- sessionId :: !Int32
- sessionEpoch :: !Int32
- topics :: !(SmallArray Topic)
- rackId :: !Text
- data Topic = Topic {
- id :: !Word128
- partitions :: !(SmallArray Partition)
- data Partition = Partition {
- index :: !Int32
- currentLeaderEpoch :: !Int32
- fetchOffset :: !Int64
- lastFetchedEpoch :: !Int32
- logStartOffset :: !Int64
- maxBytes :: !Int32
- toChunks :: Request -> Chunks
Documentation
Kafka Fetch request V13. Note: the forgotten topics array is not yet implemented. Currently, we always encode this as a zero-length array.
Request | |
|
Topic | |
|
Partition | |
|