milena-0.5.0.2: A Kafka client for Haskell.

Safe HaskellNone
LanguageHaskell2010

Network.Kafka.Consumer

Contents

Synopsis

Fetching

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.