Network.Kafka.Consumer

Fetching

ordinaryConsumerId :: ReplicaId

Default: -1

fetchRequest :: Kafka m => Offset -> Partition -> TopicName -> m FetchRequest

Construct a fetch request from the values in the state.

fetch' :: Kafka m => Handle -> FetchRequest -> m FetchResponse

Execute a fetch request and get the raw fetch response.

fetch :: Kafka m => Offset -> Partition -> TopicName -> m FetchResponse

fetchMessages :: FetchResponse -> [TopicAndMessage]

Extract out messages with their topics from a fetch response.