ProduceRequest build(short version, boolean validate)ProduceRequest
ProduceRequest is a concrete AbstractRequest with Produce API key and the following properties:
ProduceRequest is used by a Kafka producer (Kafka Producer I/O Thread actually) to send partition records (with a given acks).
ProduceRequest is created when:
-
ProduceRequest.Builderis requested to build a ProduceRequest -
ProduceRequestis requested to parse a byte buffer -
AbstractRequestis requested to parse a request (with the Produce API key)
ProduceRequest.Builder Factory Object
ProduceRequest comes with a concrete AbstractRequest.Builder factory object that can build a ProduceRequest.
ProduceRequest.Builder is used when…FIXME
Creating ProduceRequest.Builder Instance (For Given Magic Number) — forMagic Factory Method
Builder forMagic(
byte magic,
short acks,
int timeout,
Map<TopicPartition, MemoryRecords> partitionRecords,
String transactionalId)forMagic…FIXME
|
Note
|
forMagic is used excusively when Sender is requested to send a ProduceRequest.
|