Struct kafka_protocol::messages::init_producer_id_request::InitProducerIdRequest

pub struct InitProducerIdRequest {
    pub transactional_id: Option<TransactionalId>,
    pub transaction_timeout_ms: i32,
    pub producer_id: ProducerId,
    pub producer_epoch: i16,
    pub unknown_tagged_fields: BTreeMap<i32, Vec<u8>>,
}

Valid versions: 0-4

Fields

transactional_id: Option<TransactionalId>

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

Supported API versions: 0-4

transaction_timeout_ms: i32

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

producer_id: ProducerId

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

Supported API versions: 3-4

producer_epoch: i16

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

unknown_tagged_fields: BTreeMap<i32, Vec<u8>>

Other tagged fields

Trait Implementations

impl Clone for InitProducerIdRequest

fn clone(&self) -> InitProducerIdRequest

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for InitProducerIdRequest

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

Formats the value using the given formatter.

impl Decodable for InitProducerIdRequest

fn decode<B: ByteBuf>(buf: &mut B, version: i16) -> Result<Self, DecodeError>

Decode the message from the provided buffer and version.

impl Default for InitProducerIdRequest

fn default() -> Self

Returns the “default value” for a type.

impl Encodable for InitProducerIdRequest

fn encode<B: ByteBufMut>(
    &self,
    buf: &mut B,
    version: i16
) -> Result<(), EncodeError>

Encode the message into the target buffer.

fn compute_size(&self, version: i16) -> Result<usize, EncodeError>

Compute the total size of the message when encoded.

impl HeaderVersion for InitProducerIdRequest

fn header_version(version: i16) -> i16

Maps a header version to a given version for a particular API message.

impl Message for InitProducerIdRequest

const VERSIONS: VersionRange = _

The valid versions for this message.

impl PartialEq<InitProducerIdRequest> for InitProducerIdRequest

fn eq(&self, other: &InitProducerIdRequest) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Request for InitProducerIdRequest

const KEY: i16 = 22i16

The API key of this request.

type Response = InitProducerIdResponse

The response associated with this request.

impl StructuralPartialEq for InitProducerIdRequest