kafka-interchange-0.2.0.0: Serialization for kafka wire protocol

Safe Haskell	Safe-Inferred
Language	Haskell2010

Kafka.Produce.Request.V9

Contents

Request Construction

Synopsis

data Request = Request {
- transactionalId :: !(Maybe Text)
- acks :: !Acknowledgments
- timeoutMilliseconds :: !Int32
- topicData :: !(SmallArray Topic)
}
data Topic = Topic {
- name :: !Text
- partitions :: !(SmallArray Partition)
}
data Partition = Partition {
- index :: !Int32
- records :: !RecordBatch
}
encode :: Request -> Builder
toChunks :: Request -> Chunks
singleton :: Acknowledgments -> Int32 -> Text -> Int32 -> RecordBatch -> Request

Documentation

data Request Source #

Constructors

Request
Fields transactionalId :: !(Maybe Text) acks :: !Acknowledgments timeoutMilliseconds :: !Int32 topicData :: !(SmallArray Topic)

data Topic Source #

Constructors

Topic
Fields name :: !Text Topic name partitions :: !(SmallArray Partition)

data Partition Source #

Constructors

Partition
Fields index :: !Int32 records :: !RecordBatch Record batch is decoded in a separate step.

encode :: Request -> Builder Source #

toChunks :: Request -> Chunks Source #

Request Construction

singleton Source #

Arguments

:: Acknowledgments	Acknowledgements
-> Int32	Timeout milliseconds
-> Text	Topic name
-> Int32	Partition index
-> RecordBatch	Records
-> Request

Create a request for producing to a single partition of a single topic. Transactions are not used.