Struct kafka_protocol::messages::init_producer_id_request::InitProducerIdRequestBuilder

pub struct InitProducerIdRequestBuilder { /* private fields */ }

Builder for InitProducerIdRequest.

Implementations

impl InitProducerIdRequestBuilder

pub fn transactional_id(&mut self, value: Option<TransactionalId>) -> &mut Self

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

Supported API versions: 0-4

pub fn transaction_timeout_ms(&mut self, value: i32) -> &mut Self

The time in ms to wait before aborting idle transactions sent by this producer. This is only relevant if a TransactionalId has been defined.

Supported API versions: 0-4

pub fn producer_id(&mut self, value: ProducerId) -> &mut Self

The producer id. This is used to disambiguate requests if a transactional id is reused following its expiration.

Supported API versions: 3-4

pub fn producer_epoch(&mut self, value: i16) -> &mut Self

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.

Supported API versions: 3-4

pub fn unknown_tagged_fields( &mut self, value: BTreeMap<i32, Vec<u8>> ) -> &mut Self

Other tagged fields

pub fn build( &self ) -> Result<InitProducerIdRequest, InitProducerIdRequestBuilderError>

Builds a new InitProducerIdRequest.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for InitProducerIdRequestBuilder

fn clone(&self) -> InitProducerIdRequestBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for InitProducerIdRequestBuilder

fn default() -> Self

Returns the “default value” for a type.