Struct ProduceMessage

pub struct ProduceMessage<'a, 'b> {
    pub key: Option<&'b [u8]>,
    pub value: Option<&'b [u8]>,
    pub topic: &'a str,
    pub partition: i32,
}

Message data to be sent/produced to a particular topic partition. See KafkaClient::produce_messages and Producer::send.

Fields

key: Option<&'b [u8]>

The “key” data of this message.

value: Option<&'b [u8]>

The “value” data of this message.

topic: &'a str

The topic to produce this message to.

partition: i32

The partition (of the corresponding topic) to produce this message to.

Implementations

impl<'a, 'b> ProduceMessage<'a, 'b>

pub fn new( topic: &'a str, partition: i32, key: Option<&'b [u8]>, value: Option<&'b [u8]>, ) -> Self

A convenient constructor method to create a new produce message with all attributes specified.

Trait Implementations

impl<'a, 'b> AsRef<ProduceMessage<'a, 'b>> for ProduceMessage<'a, 'b>

fn as_ref(&self) -> &Self

Converts this type into a shared reference of the (usually inferred) input type.

impl<'a, 'b> Debug for ProduceMessage<'a, 'b>

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

Formats the value using the given formatter.