| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Network.Kafka.Consumer
Contents
- ordinaryConsumerId :: ReplicaId
- fetchRequest :: Offset -> Partition -> TopicName -> Kafka FetchRequest
- fetch' :: Handle -> FetchRequest -> Kafka FetchResponse
- fetch :: Offset -> Partition -> TopicName -> Kafka FetchResponse
- fetchMessages :: FetchResponse -> [TopicAndMessage]
Fetching
ordinaryConsumerId :: ReplicaId Source
Default: -1
fetchRequest :: Offset -> Partition -> TopicName -> Kafka FetchRequest Source
Construct a fetch request from the values in the state.
fetch' :: Handle -> FetchRequest -> Kafka FetchResponse Source
Execute a fetch request and get the raw fetch response.
fetchMessages :: FetchResponse -> [TopicAndMessage] Source
Extract out messages with their topics from a fetch response.