Safe Haskell	Safe-Inferred
Language	Haskell2010

Kafka.InitProducerId.Request.V4

Contents

Construction

Synopsis

data Request = Request {
- transactionalId :: !(Maybe Text)
- transactionTimeoutMilliseconds :: !Int32
- producerId :: !Int64
- producerEpoch :: !Int16
}
toChunks :: Request -> Chunks
request :: Request

Documentation

data Request Source #

Kafka Init Producer ID request V4.

Constructors

Request

Fields

transactionalId :: !(Maybe Text)
The transactional id, or null if the producer is not transactional.
transactionTimeoutMilliseconds :: !Int32
The time in ms to wait before aborting idle transactions sent by this producer. This is only relevant if a TransactionalId has been defined.
producerId :: !Int64
The producer id. This is used to disambiguate requests if a transactional id is reused following its expiration. Typically, this should be set to -1.
producerEpoch :: !Int16
The producer's current epoch. This will be checked against the producer epoch on the broker, and the request will return an error if they do not match. Setting this to -1 disables this check, which is typically what you want.

toChunks :: Request -> Chunks Source #

Construction

request :: Request Source #

An empty request. Everything in this request is set to something that means "this is not being provided to the broker". This is the most common value of this type to use. Note that transactionTimeoutMilliseconds is set to 2147483647 because this is what the kafka-console-producer does.