Struct ProduceRequest 

pub struct ProduceRequest {
    pub transactional_id: NullableString,
    pub acks: Int16,
    pub timeout_ms: Int32,
    pub topic_data: Vec<ProduceRequestTopicData>,
}

Fields

transactional_id: NullableString

The transactional ID, or null if the producer is not transactional.

Added in version 3.

acks: Int16

The number of acknowledgments the producer requires the leader to have received before considering a request complete.

Allowed values: 0 for no acknowledgments, 1 for only the leader and -1 for the full ISR.

timeout_ms: Int32

The timeout to await a response in milliseconds.

topic_data: Vec<ProduceRequestTopicData>

Each topic to produce to.

Trait Implementations

impl Debug for ProduceRequest

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RequestBody for ProduceRequest

const API_VERSION_RANGE: ApiVersionRange

That’s enough for for.

Note that we do not support produce request prior to version 3, since this is the version when message version 2 was introduced (KIP-98).

const API_KEY: ApiKey = ApiKey::Produce

Kafka API key.

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

The first version of the messages (not of the header) that uses tagged fields, if any.

type ResponseBody = ProduceResponse

The response type that will follow when issuing this request.

const FIRST_TAGGED_FIELD_IN_RESPONSE_VERSION: ApiVersion = Self::FIRST_TAGGED_FIELD_IN_REQUEST_VERSION

Normally the same as FIRST_TAGGED_FIELD_IN_REQUEST_VERSION but there are some special snowflakes.

impl<W> WriteVersionedType<W> for ProduceRequest

where W: Write,

fn write_versioned( &self, writer: &mut W, version: ApiVersion, ) -> Result<(), WriteVersionedError>