Network.Kafka.Consumer

Fetching

ordinaryConsumerId :: ReplicaId

Default: -1

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

Construct a fetch request from the values in the state.

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

Execute a fetch request and get the raw fetch response.

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

fetchMessages :: FetchResponse -> [TopicAndMessage]

Extract out messages with their topics from a fetch response.