| Safe Haskell | Safe-Inferred |
|---|---|
| Language | Haskell2010 |
Kafka.Produce.Request.V9
Contents
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
Constructors
| Request | |
Fields
| |
Constructors
| Topic | |
Fields
| |
Constructors
| Partition | |
Fields
| |
Request Construction
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.