ProduceRequest constructor

ProduceRequest(
  1. int requiredAcks,
  2. int timeout,
  3. List<ProduceEnvelope> messages
)

Creates Kafka ProduceRequest.

The requiredAcks field indicates how many acknowledgements the servers should receive before responding to the request. The timeout field provides a maximum time in milliseconds the server can await the receipt of the number of acknowledgements in requiredAcks.

Implementation

ProduceRequest(this.requiredAcks, this.timeout, this.messages) : super();