milena-0.5.2.2: A Kafka client for Haskell.

Safe HaskellNone
LanguageHaskell2010

Network.Kafka.Consumer

Contents

Synopsis

Fetching

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

Construct a fetch request from the values in the state.

fetch' :: Kafka m => Handle -> FetchRequest -> m 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.