ProduceRequest is a concrete AbstractRequest with Produce API key and the following properties:

  • Version

  • acks

  • timeout

  • Partition records (Map<TopicPartition, MemoryRecords>)

  • Transactional ID

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.Builder Factory Object

ProduceRequest comes with a concrete AbstractRequest.Builder factory object that can build a ProduceRequest.

ProduceRequest build(short version, boolean validate)

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 is used excusively when Sender is requested to send a ProduceRequest.

Creating ProduceRequest from Byte Buffer — parse Factory Method

ProduceRequest parse(ByteBuffer buffer, short version)


parse is used when…​FIXME

results matching ""

    No results matching ""