kafka-client-0.7.0.1: Low-level Haskell client library for Apache Kafka 0.7.

Safe HaskellNone
LanguageHaskell2010

Kafka.Internal.Response

Synopsis

Documentation

type Response a = Either Error a Source

A response from Kafka can either be a failure or the value that was expected.

data FetchResponse Source

Result of a single Kafka Fetch.

Constructors

FetchResponse 

Fields

fetchMessages :: [ByteString]

List of messages returned in the response for the Fetch request.

fetchNewOffset :: !Offset

New offset at which the next Fetch request should start reading in the same topic and partition to access the messages that follow the messages returned in this response.

getFetchResponse :: Fetch -> Get FetchResponse Source

Parses a single FetchResponse for the given Fetch request.

getMultiFetchResponse :: [Fetch] -> Get [FetchResponse] Source

Parses FetchResponses for each of the given Fetch requests.

getOffsetsResponse :: Get [Offset] Source

Parses the response for an Offsets request.