Struct RecordMetadata 

pub struct RecordMetadata {
    pub topic: String,
    pub partition: i32,
    pub offset: i64,
    pub timestamp_ms: i64,
    pub serialized_key_size: i32,
    pub serialized_value_size: i32,
}

What the producer learned about a record that the broker acknowledged.

Kafka’s RecordMetadata carries the same fields.

Fields

topic: String

The topic of the record.

partition: i32

offset: i64

The offset of the record in the partition. It is -1 when the offset is not known, which is always the case with acks=0. Kafka’s RecordMetadata constructor keeps a base offset of -1 and does not add the index of the record in its batch.

timestamp_ms: i64

The log append time from the broker when the topic uses message.timestamp.type=LogAppendTime, and else the create time of the record. Kafka’s FutureRecordMetadata.timestamp makes the same choice.

serialized_key_size: i32

The size of the key in bytes, or -1 for a null key.

serialized_value_size: i32

The size of the value in bytes, or -1 for a null value.

Trait Implementations

impl Clone for RecordMetadata

fn clone(&self) -> RecordMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecordMetadata

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

Formats the value using the given formatter.

impl Eq for RecordMetadata

impl PartialEq for RecordMetadata

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for RecordMetadata