Safe Haskell | None |
---|---|
Language | Haskell2010 |
Kafka.Internal.Request
- data Produce = Produce {}
- putProduceRequest :: Produce -> Put
- putMultiProduceRequest :: [Produce] -> Put
- data Fetch = Fetch {
- fetchTopic :: !Topic
- fetchPartition :: !Partition
- fetchOffset :: !Offset
- fetchSize :: !Size
- putFetchRequest :: Fetch -> Put
- putMultiFetchRequest :: [Fetch] -> Put
- data Offsets = Offsets {}
- putOffsetsRequest :: Offsets -> Put
Documentation
A request to send messages down a Kafka topic-partition pair.
Produce requests do not have a corresponding response. There is no way of
knowing in Kafka 0.7 if a message was successfully Produce
d.
Constructors
Produce | |
Fields
|
putProduceRequest :: Produce -> Put Source
Put
s the given single Produce
request.
putMultiProduceRequest :: [Produce] -> Put Source
Put
s the given MultiProduce
request.
A request to fetch messages from a particular Kafka topic-partition pair.
FetchResponse
contains responses for this kind of request.
Constructors
Fetch | |
Fields
|
putFetchRequest :: Fetch -> Put Source
Put
s the given single Fetch
request.
putMultiFetchRequest :: [Fetch] -> Put Source
Put
s the given MultiFetch
request.
A request to retrieve offset information from Kafka.
The response for this kind of request is a list of Offset
s.
Constructors
Offsets | |
Fields
|
putOffsetsRequest :: Offsets -> Put Source
Put
s the given Offsets
request.