Struct CommandProducer 

pub struct CommandProducer {
    pub topic: String,
    pub producer_id: u64,
    pub request_id: u64,
    pub producer_name: Option<String>,
    pub encrypted: Option<bool>,
    pub metadata: Vec<KeyValue>,
    pub schema: Option<Schema>,
    pub epoch: Option<u64>,
    pub user_provided_producer_name: Option<bool>,
}

Fields

topic: String

producer_id: u64

request_id: u64

producer_name: Option<String>

encrypted: Option<bool>

metadata: Vec<KeyValue>

schema: Option<Schema>

epoch: Option<u64>

If producer reconnect to broker, the epoch of this producer will +1

user_provided_producer_name: Option<bool>

Indicate the name of the producer is generated or user provided Use default true here is in order to be forward compatible with the client

Implementations

impl CommandProducer

pub fn producer_name(&self) -> &str

Returns the value of producer_name, or the default value if producer_name is unset.

pub fn encrypted(&self) -> bool

Returns the value of encrypted, or the default value if encrypted is unset.

pub fn epoch(&self) -> u64

Returns the value of epoch, or the default value if epoch is unset.

pub fn user_provided_producer_name(&self) -> bool

Returns the value of user_provided_producer_name, or the default value if user_provided_producer_name is unset.

Trait Implementations

impl Clone for CommandProducer

fn clone(&self) -> CommandProducer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommandProducer

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

Formats the value using the given formatter.

impl Default for CommandProducer

fn default() -> Self

Returns the “default value” for a type.

impl Message for CommandProducer

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

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

where B: BufMut, Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>

where B: BufMut, Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError>

where B: Buf, Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>

where B: Buf, Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>

where B: Buf, Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>

where B: Buf, Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for CommandProducer

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for CommandProducer